[IOTDB-1277] support IoTDB as Flink source (#2963)
authorRing-k <36235611+Ring-k@users.noreply.github.com>
Fri, 2 Apr 2021 10:01:24 +0000 (18:01 +0800)
committerGitHub <noreply@github.com>
Fri, 2 Apr 2021 10:01:24 +0000 (18:01 +0800)
commit2825e47abdb26a09c1031134dcd9ad2cce671538
tree7ea77f8d2b8bd2cfef4d1f602dfd789f516857e8
parent2619fe0d96898096f3229ad69af7d2fdf26029c1
[IOTDB-1277] support IoTDB as Flink source  (#2963)
12 files changed:
docs/UserGuide/Ecosystem Integration/Flink IoTDB.md
example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSource.java [new file with mode: 0644]
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java [new file with mode: 0644]
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBOptions.java [new file with mode: 0644]
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java [moved from flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBOptions.java with 79% similarity]
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSourceOptions.java [new file with mode: 0644]
flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java
flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java
flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkInsertTest.java