Skip to content

Commit 933926a

Browse files
author
sishu@dtstack.com
committed
update
1 parent cb28f52 commit 933926a

File tree

38 files changed

+1199
-106
lines changed

38 files changed

+1199
-106
lines changed

‎.gitignore‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,7 @@
11
target
22
.idea/
33
/.idea/*
4-
/target
5-
target
4+
target/
65
.class
76
.project
87
.classpath

‎core/pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
33
<parent>
44
<artifactId>flink.sql</artifactId>
5-
<groupId>com.dtstack.flinkx</groupId>
5+
<groupId>com.dtstack.flink</groupId>
66
<version>1.0-SNAPSHOT</version>
77
<relativePath>../pom.xml</relativePath>
88
</parent>

‎elasticsearch/pom.xml‎

Lines changed: 0 additions & 19 deletions
This file was deleted.

elasticsearch/elasticsearch-sink/pom.xml renamed to elasticsearch5/elasticsearch5-sink/pom.xml

Lines changed: 4 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -3,30 +3,16 @@
33
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
44
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
55
<parent>
6-
<artifactId>sql.elasticsearch</artifactId>
7-
<groupId>com.dtstack.flinkx</groupId>
6+
<artifactId>sql.elasticsearch5</artifactId>
7+
<groupId>com.dtstack.flink</groupId>
88
<version>1.0-SNAPSHOT</version>
99
</parent>
1010
<modelVersion>4.0.0</modelVersion>
1111

12-
<artifactId>sql.sink.elasticsearch</artifactId>
13-
<name>elasticsearch-sink</name>
12+
<artifactId>sql.sink.elasticsearch5</artifactId>
13+
<name>elasticsearch5-sink</name>
1414

1515
<dependencies>
16-
<dependency>
17-
<groupId>junit</groupId>
18-
<artifactId>junit</artifactId>
19-
<version>3.8.1</version>
20-
<scope>test</scope>
21-
</dependency>
22-
23-
<dependency>
24-
<groupId>com.dtstack.flinkx</groupId>
25-
<artifactId>sql.core</artifactId>
26-
<version>1.0-SNAPSHOT</version>
27-
<scope>provided</scope>
28-
</dependency>
29-
3016
<dependency>
3117
<groupId>org.apache.flink</groupId>
3218
<artifactId>flink-connector-elasticsearch5_2.11</artifactId>

elasticsearch/elasticsearch-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/CustomerSinkFunc.java renamed to elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/CustomerSinkFunc.java

File renamed without changes.

elasticsearch/elasticsearch-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ElasticsearchSink.java renamed to elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ElasticsearchSink.java

File renamed without changes.

elasticsearch/elasticsearch-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/EsUtil.java renamed to elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/EsUtil.java

File renamed without changes.

elasticsearch/elasticsearch-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchSinkParser.java renamed to elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchSinkParser.java

File renamed without changes.

elasticsearch/elasticsearch-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchTableInfo.java renamed to elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchTableInfo.java

File renamed without changes.

‎elasticsearch5/pom.xml‎

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<parent>
6+
<artifactId>flink.sql</artifactId>
7+
<groupId>com.dtstack.flink</groupId>
8+
<version>1.0-SNAPSHOT</version>
9+
</parent>
10+
<modelVersion>4.0.0</modelVersion>
11+
12+
<artifactId>sql.elasticsearch5</artifactId>
13+
<packaging>pom</packaging>
14+
<modules>
15+
<module>elasticsearch5-sink</module>
16+
</modules>
17+
<dependencies>
18+
<dependency>
19+
<groupId>junit</groupId>
20+
<artifactId>junit</artifactId>
21+
<version>3.8.1</version>
22+
<scope>test</scope>
23+
</dependency>
24+
25+
<dependency>
26+
<groupId>com.dtstack.flink</groupId>
27+
<artifactId>sql.core</artifactId>
28+
<version>1.0-SNAPSHOT</version>
29+
<scope>provided</scope>
30+
</dependency>
31+
32+
</dependencies>
33+
34+
</project>

0 commit comments

Comments
 (0)