You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2021/12/03 02:52:37 UTC
[incubator-inlong] branch master updated (e6b6468 -> 0d4ff86)

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

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


    from e6b6468  [INLONG-1897] form cannot use chain name (#1899)
     add 0d4ff86  [INLONG-810] Sort Module Support store data to ApacheDoris  (#1846)

No new revisions were added by this update.

Summary of changes:
 .../inlong/sort/configuration/Constants.java       |   2 +
 .../inlong/sort/protocol/sink/DorisSinkInfo.java   | 109 ++++++++++
 .../org/apache/inlong/sort/flink/Entrance.java     |   8 +
 .../DorisMultiSinkFunction.java}                   |  59 +++---
 .../DorisSinkFunction.java}                        |  54 ++---
 .../inlong/sort/flink/doris/DorisSinkOptions.java  |  93 +++++++++
 .../sort/flink/doris/DorisSinkOptionsBuilder.java  | 117 +++++++++++
 .../sort/flink/doris/load/DorisBeInfoResponse.java |  45 +++--
 .../sort/flink/doris/load/DorisConnectParam.java   | 110 +++++++++++
 .../sort/flink/doris/load/DorisHttpUtils.java      |  99 ++++++++++
 .../inlong/sort/flink/doris/load/DorisRespond.java |  64 ++++++
 .../sort/flink/doris/load/DorisRespondMsg.java     | 219 +++++++++++++++++++++
 .../load/DorisRowConverter.java}                   |  25 ++-
 .../sort/flink/doris/load/DorisStreamLoad.java     | 149 ++++++++++++++
 .../sort/flink/doris/output/DorisOutputFormat.java | 171 ++++++++++++++++
 .../inlong/sort/flink/doris/TestDorisSink.java     |  66 +++++++
 16 files changed, 1292 insertions(+), 98 deletions(-)
 create mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/DorisSinkInfo.java
 copy inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{clickhouse/ClickHouseMultiSinkFunction.java => doris/DorisMultiSinkFunction.java} (69%)
 copy inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{clickhouse/ClickHouseSinkFunction.java => doris/DorisSinkFunction.java} (56%)
 create mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/DorisSinkOptions.java
 create mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/DorisSinkOptionsBuilder.java
 copy inlong-dataproxy-sdk/src/main/java/org/apache/inlong/dataproxy/codec/ErrorCode.java => inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisBeInfoResponse.java (56%)
 create mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisConnectParam.java
 create mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisHttpUtils.java
 create mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisRespond.java
 create mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisRespondMsg.java
 copy inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{clickhouse/output/AbstractClickHouseOutputFormat.java => doris/load/DorisRowConverter.java} (62%)
 create mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisStreamLoad.java
 create mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/doris/output/DorisOutputFormat.java
 create mode 100644 inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/flink/doris/TestDorisSink.java