This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch NewDoc
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 506c8df fix conflict
add 2619fe0 [IOTDB-1230]Support cross multi time partition when loading
one TsFile (#2864)
add 2825e47 [IOTDB-1277] support IoTDB as Flink source (#2963)
add 087d79b Merge branch 'master' into NewDoc
No new revisions were added by this update.
Summary of changes:
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 105 +++++++-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 5 +-
.../org/apache/iotdb/flink/FlinkIoTDBSource.java | 94 +++++++
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 1 +
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 1 -
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 2 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 13 +-
.../java/org/apache/iotdb/flink/IoTDBSource.java | 100 ++++++++
.../apache/iotdb/flink/options/IoTDBOptions.java | 70 ++++++
.../IoTDBSinkOptions.java} | 51 +---
.../iotdb/flink/options/IoTDBSourceOptions.java | 36 ++-
.../flink/DefaultIoTSerializationSchemaTest.java | 6 +-
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 5 +-
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 5 +-
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 5 +-
.../engine/storagegroup/StorageGroupProcessor.java | 6 +-
.../db/engine/storagegroup/TsFileResource.java | 9 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 32 ++-
.../storagegroup/timeindex/FileTimeIndex.java | 28 ++-
.../engine/storagegroup/timeindex/ITimeIndex.java | 21 +-
.../iotdb/db/engine/upgrade/UpgradeTask.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 23 +-
...lineUpgradeTool.java => TsFileRewriteTool.java} | 253 ++++++++++---------
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 263 ++------------------
.../iotdb/db/utils/TsFileRewriteToolTest.java | 273 +++++++++++++++++++++
25 files changed, 933 insertions(+), 476 deletions(-)
create mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSource.java
create mode 100644
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java
create mode 100644
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBOptions.java
rename
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/{IoTDBOptions.java
=> options/IoTDBSinkOptions.java} (79%)
copy
server/src/test/java/org/apache/iotdb/db/mqtt/PayloadFormatManagerTest.java =>
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSourceOptions.java
(52%)
copy
server/src/main/java/org/apache/iotdb/db/tools/{upgrade/TsFileOnlineUpgradeTool.java
=> TsFileRewriteTool.java} (69%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/TsFileRewriteToolTest.java
