You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/10/25 08:24:13 UTC
[inlong] branch master updated (f8b1efa7a -> ae5a00955)

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

healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from f8b1efa7a [INLONG-6274][Sort] Support multiple sink for IcebergLoadNode (#6215)
     add ae5a00955 [INLONG-6212][Sort] Support multiple sinks for DorisLoadNode (#6213)

No new revisions were added by this update.

Summary of changes:
 .../sort/protocol/constant/DorisConstant.java      |  19 ++
 .../sort/protocol/node/load/DorisLoadNode.java     |  73 ++++-
 .../base/format/CanalJsonDynamicSchemaFormat.java  |  43 ++-
 .../format/DebeziumJsonDynamicSchemaFormat.java    |  53 +++
 .../sort/base/format/JsonDynamicSchemaFormat.java  |  85 ++++-
 inlong-sort/sort-connectors/doris/pom.xml          |  21 +-
 .../table/DorisDynamicSchemaOutputFormat.java      | 365 +++++++++++++++++++++
 .../sort/doris/table/DorisDynamicTableFactory.java | 339 +++++++++++++++++++
 .../sort/doris/table/DorisDynamicTableSink.java    | 110 +++++++
 .../inlong/sort/doris/table/DorisStreamLoad.java   | 187 +++++++++++
 .../org.apache.flink.table.factories.Factory       |   2 +-
 ...qlParseTest.java => DorisMultipleSinkTest.java} |  72 ++--
 licenses/inlong-sort-connectors/LICENSE            |   7 +
 13 files changed, 1305 insertions(+), 71 deletions(-)
 create mode 100644 inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
 create mode 100644 inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicTableFactory.java
 create mode 100644 inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicTableSink.java
 create mode 100644 inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisStreamLoad.java
 copy inlong-sort/sort-connectors/{jdbc => doris}/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory (92%)
 copy inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/{DecimalFormatSqlParseTest.java => DorisMultipleSinkTest.java} (59%)