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 376df66 Fix the wrong logo image link (#929)
add 0c8ede5 Add Druid Flink Source plugin (#923)
No new revisions were added by this update.
Summary of changes:
docs/en/configuration/source-plugins/Druid.md | 51 +++++
pom.xml | 7 +
seatunnel-connectors/pom.xml | 1 +
.../pom.xml | 14 +-
.../seatunnel/flink/source/DruidInputFormat.java | 253 +++++++++++++++++++++
.../seatunnel/flink/source/DruidSource.java} | 137 ++++-------
.../apache/seatunnel/flink/source/DruidSql.java | 114 ++++++++++
.../org.apache.seatunnel.flink.BaseFlinkSource | 1 +
8 files changed, 480 insertions(+), 98 deletions(-)
create mode 100644 docs/en/configuration/source-plugins/Druid.md
copy seatunnel-connectors/{seatunnel-connector-flink-fake =>
seatunnel-connector-flink-druid}/pom.xml (82%)
create mode 100644
seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java
copy
seatunnel-connectors/{seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
=>
seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java}
(59%)
create mode 100644
seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSql.java
create mode 100644
seatunnel-connectors/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
