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
