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
