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/01/04 05:42:26 UTC

[incubator-seatunnel] branch dev updated (376df66 -> 0c8ede5)

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