IoTDB-Flink-Connector

IoTDB integration for Apache Flink. This module includes the iotdb sink that allows a flink job to write events into timeseries.

IoTDBSink

To use the IoTDBSink, you need construct an instance of it by specifying IoTDBOptions and IoTSerializationSchema instances. The IoTDBSink send only one event after another by default, but you can change to batch by invoking withBatchSize(int).

Examples

The following is an example which receiving events from sensor source and then sending events to iotdb.

       StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

       IoTDBOptions options = new IoTDBOptions();
       options.setHost("127.0.0.1");
       options.setPort(6667);
       options.setUser("root");
       options.setPassword("root");
       options.setStorageGroup("root.sg");
       options.setTimeseries(Lists.newArrayList("root.sg.d1.s1"));

       IoTSerializationSchema serializationSchema = new DefaultIoTSerializationSchema();
       IoTDBSink ioTDBSink = new IoTDBSink(options, serializationSchema)
               // enable batching
               .withBatchSize(10)
               ;

       env.addSource(new SensorSource())
               .name("sensor-source")
               .setParallelism(1)
               .addSink(ioTDBSink)
               .name("iotdb-sink")
               .setParallelism(1)
       ;

       env.execute("iotdb-flink-example");