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/10 12:08:37 UTC

[incubator-seatunnel] branch dev updated (9b73e4c -> 49d77f5)

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 9b73e4c  [SeaTunnel#983] Speed up CI/CD with multi threads (#984)
     add 49d77f5  [SeaTunnel#969]Add Druid Flink Sink plugin (#970)

No new revisions were added by this update.

Summary of changes:
 docs/en/configuration/sink-plugins/Druid.md        |  29 +++
 pom.xml                                            |   6 +
 .../seatunnel-connector-flink-druid/pom.xml        |   4 +
 .../seatunnel/flink/sink/DruidOutputFormat.java    | 208 +++++++++++++++++++++
 .../apache/seatunnel/flink/sink/DruidSink.java}    |  53 ++----
 .../org.apache.seatunnel.flink.BaseFlinkSink       |   1 +
 6 files changed, 263 insertions(+), 38 deletions(-)
 create mode 100644 docs/en/configuration/sink-plugins/Druid.md
 create mode 100644 seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java
 copy seatunnel-connectors/{seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java => seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java} (61%)
 create mode 100644 seatunnel-connectors/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink