You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/02/08 03:41:47 UTC

[incubator-seatunnel] branch dev updated (674e6c1 -> 7b237be)

This is an automated email from the ASF dual-hosted git repository.

kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git.


    from 674e6c1  [Feature] [license] Correct the format of Typesafe license header (#1200)
     add 7b237be  [Feature] [connector]  Add InfluxDB Flink Source (#1048)

No new revisions were added by this update.

Summary of changes:
 .../flink/configuration/source-plugins/InfluxDb.md |  47 +++++
 .../flink/source/InfluxDbInputFormat.java          | 199 +++++++++++++++++++++
 .../seatunnel/flink/source/InfluxDbSource.java     | 127 +++++++++++++
 .../seatunnel/flink/source/InfluxDbSql.java}       |  61 +++----
 .../org.apache.seatunnel.flink.BaseFlinkSource     |   1 +
 5 files changed, 400 insertions(+), 35 deletions(-)
 create mode 100644 docs/en/flink/configuration/source-plugins/InfluxDb.md
 create mode 100644 seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbInputFormat.java
 create mode 100644 seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSource.java
 copy seatunnel-connectors/{seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSql.java => seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSql.java} (54%)
 create mode 100644 seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource