Google Git
Sign in
apache / iotdb / refs/tags/v0.12.3 / . / example / flink
tree: eda6aefcbeac2cd90333686ef6268a78a459fff9 [path history] [tgz]
  1. src/
  2. pom.xml
  3. README.md
example/flink/README.md

IoTDB-Flink-Connector Example

Function

The example is to show how to send data to a IoTDB server from a Flink job.

Usage

  • Launch the IoTDB server.
  • Run org.apache.iotdb.flink.FlinkIoTDBSink.java to run the flink job on local mini cluster.

TsFile-Flink-Connector Example

Usage

  • Run org.apache.iotdb.flink.FlinkTsFileBatchSource.java to create a tsfile and read it via a flink DataSet job on local mini cluster.
  • Run org.apache.iotdb.flink.FlinkTsFileStreamSource.java to create a tsfile and read it via a flink DataStream job on local mini cluster.
  • Run org.apache.iotdb.flink.FlinkTsFileBatchSink.java to write a tsfile via a flink DataSet job on local mini cluster and print the content to stdout.
  • Run org.apache.iotdb.flink.FlinkTsFileStreamSink.java to write a tsfile via a flink DataStream job on local mini cluster and print the content to stdout.