apache / seatunnel

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
https://seatunnel.apache.org/
Apache License 2.0
7.79k stars 1.74k forks source link

[Feature][Connectors] Add IoTDB Flink Source #1288

Open asdf2014 opened 2 years ago

asdf2014 commented 2 years ago

Search before asking

Description

IoTDb

Source plugin: IoTDb [Flink]

Description

Read data from IoTDB.

Options

name type required default value
url String yes -
storage String yes -
fields List<String> yes -
field_types List<String> yes -

url [String]

The URL of IoTDB Server.

storage [String]

The storage name in IoTDB.

fields [List<String>]

The list of Field in IoTDB.

field_types [List<String>]

The list of Field Types in IoTDB.

Example

IoTDbSource {
  url = "jdbc:iotdb://127.0.0.1:6667/"
  storage = "root.demo"
  fields = ["s0"]
  field_types = ["INT32"]
}

Usage Scenario

No response

Related issues

No response

Are you willing to submit a PR?

Code of Conduct

asdf2014 commented 2 years ago

Also you can get more details of Apache IoTDB from my personal blog, FYI, https://yuzhouwan.com/posts/201221/