This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 2619fe0 [IOTDB-1230]Support cross multi time partition when loading
one TsFile (#2864)
add 2825e47 [IOTDB-1277] support IoTDB as Flink source (#2963)
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/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 +-
12 files changed, 419 insertions(+), 76 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%)
