This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 4652631edcfe26479e750ce99a5663f547912a4d Author: 仲炜 <[email protected]> AuthorDate: Wed Apr 1 17:08:47 2020 +0800 address comments and push to test travis changes. --- .travis.yml | 2 +- example/flink/pom.xml | 2 +- {flink-tsfile => flink-tsfile-connector}/README.md | 2 +- {flink-tsfile => flink-tsfile-connector}/pom.xml | 3 +-- .../src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java | 0 .../main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java | 0 .../src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java | 0 .../main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java | 0 .../java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java | 0 .../java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java | 0 .../org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java | 0 .../src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java | 0 pom.xml | 2 +- 13 files changed, 5 insertions(+), 6 deletions(-) diff --git a/.travis.yml b/.travis.yml index 3924e33..6b91e6d 100644 --- a/.travis.yml +++ b/.travis.yml @@ -137,7 +137,7 @@ matrix: # now, grafana has no tests; spark-* tests are written by scala - mvn post-integration-test -Pcode-coverage -Pcoveralls -pl '!site','!distribution' -am after_success: - - mvn coveralls:report -DserviceName=travis_ci -pl tsfile,server,jdbc,client,session,hive-connector,flink-iotdb-connector + - mvn coveralls:report -DserviceName=travis_ci -pl tsfile,server,jdbc,client,session,hive-connector,flink-iotdb-connector,flink-tsfile-connector - os: linux name: website checker dist: xenial diff --git a/example/flink/pom.xml b/example/flink/pom.xml index f82d550..e46e834 100644 --- a/example/flink/pom.xml +++ b/example/flink/pom.xml @@ -48,7 +48,7 @@ </dependency> <dependency> <groupId>org.apache.iotdb</groupId> - <artifactId>flink-tsfile</artifactId> + <artifactId>flink-tsfile-connector</artifactId> <version>${project.version}</version> </dependency> </dependencies> diff --git a/flink-tsfile/README.md b/flink-tsfile-connector/README.md similarity index 97% rename from flink-tsfile/README.md rename to flink-tsfile-connector/README.md index 1f3f28c..a571de7 100644 --- a/flink-tsfile/README.md +++ b/flink-tsfile-connector/README.md @@ -23,7 +23,7 @@ ## 1. About TsFile-Flink-Connector TsFile-Flink-Connector implements the support of Flink for external data sources of Tsfile type. -This enables users to read, write and query Tsfile by Flink via DataStream/DataSet API. +This enables users to read Tsfile by Flink via DataStream/DataSet API. With this connector, you can * load a single TsFile or multiple TsFiles(only for DataSet), from either the local file system or hdfs, into Flink diff --git a/flink-tsfile/pom.xml b/flink-tsfile-connector/pom.xml similarity index 96% rename from flink-tsfile/pom.xml rename to flink-tsfile-connector/pom.xml index 0a66fa2..3879873 100644 --- a/flink-tsfile/pom.xml +++ b/flink-tsfile-connector/pom.xml @@ -27,9 +27,8 @@ <version>0.10.0-SNAPSHOT</version> <relativePath>../pom.xml</relativePath> </parent> - <artifactId>flink-tsfile</artifactId> + <artifactId>flink-tsfile-connector</artifactId> <packaging>jar</packaging> - <name>IoTDB Flink-TsFile</name> <dependencies> <dependency> <groupId>org.apache.iotdb</groupId> diff --git a/flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java b/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java similarity index 100% rename from flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java rename to flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java diff --git a/flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java b/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java similarity index 100% rename from flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java rename to flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java diff --git a/flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java b/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java similarity index 100% rename from flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java rename to flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java diff --git a/flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java b/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java similarity index 100% rename from flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java rename to flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java diff --git a/flink-tsfile/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java similarity index 100% rename from flink-tsfile/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java rename to flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java diff --git a/flink-tsfile/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java similarity index 100% rename from flink-tsfile/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java rename to flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java diff --git a/flink-tsfile/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java similarity index 100% rename from flink-tsfile/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java rename to flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java diff --git a/flink-tsfile/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java similarity index 100% rename from flink-tsfile/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java rename to flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java diff --git a/pom.xml b/pom.xml index 7b5b081..647466f 100644 --- a/pom.xml +++ b/pom.xml @@ -88,9 +88,9 @@ <module>example</module> <module>grafana</module> <module>spark-tsfile</module> - <module>flink-tsfile</module> <module>hadoop</module> <module>spark-iotdb-connector</module> + <module>flink-tsfile-connector</module> <module>flink-iotdb-connector</module> <module>distribution</module> <module>hive-connector</module>
