This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 48b0360 not delete incompatible file in file level api (#1007)
new 0f782ad add TsFileInputFormat for reading TsFiles in flink.
new 2feb0ce try to fix windows test
new bee90f7 add docs and rename util classes.
new 4652631 address comments and push to test travis changes.
new 4846b4a fix compile error caused by rebase
new b24cdde fix compile error caused by rebase and add a new test to help
maintain the TSFileConfigUtil.
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.travis.yml | 2 +-
example/flink/README.md | 7 +
example/flink/pom.xml | 10 +
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 80 +++++++
.../iotdb/flink/FlinkTsFileStreamSource.java | 84 ++++++++
.../java/org/apache/iotdb/flink/TsFlieUtils.java | 72 +++++++
flink-tsfile-connector/README.md | 93 +++++++++
{example/flink => flink-tsfile-connector}/pom.xml | 19 +-
.../apache/iotdb/flink/tsfile/RowRecordParser.java | 46 +++++
.../iotdb/flink/tsfile/RowRowRecordParser.java | 120 +++++++++++
.../iotdb/flink/tsfile/TsFileInputFormat.java | 168 +++++++++++++++
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 65 ++++++
.../flink/tsfile/RowTsFileInputFormatITCase.java | 109 ++++++++++
.../flink/tsfile/RowTsFileInputFormatTest.java | 89 ++++++++
.../flink/tsfile/RowTsFileInputFormatTestBase.java | 118 +++++++++++
.../util/TSFileConfigUtilCompletenessTest.java | 84 ++++++++
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 230 +++++++++++++++++++++
pom.xml | 2 +
.../iotdb/tsfile/common/conf/TSFileConfig.java | 3 +-
.../iotdb/tsfile/read/expression/IExpression.java | 4 +-
.../tsfile/read/expression/QueryExpression.java | 3 +-
21 files changed, 1399 insertions(+), 9 deletions(-)
create mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java
create mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
create mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/TsFlieUtils.java
create mode 100644 flink-tsfile-connector/README.md
copy {example/flink => flink-tsfile-connector}/pom.xml (73%)
create mode 100644
flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java
create mode 100644
flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java
create mode 100644
flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java
create mode 100644
flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TSFileConfigUtilCompletenessTest.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java
