This is an automated email from the ASF dual-hosted git repository.
diwu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
from 007d524 [fix](cdc) configure table buckets for a single sink (#307)
add 0566b92 [Feature](sink) add copy mode to sink (#312)
No new revisions were added by this update.
Summary of changes:
...amLoadException.java => CopyLoadException.java} | 12 +-
...ventType.java => DorisAbstractCommittable.java} | 7 +-
.../apache/doris/flink/sink/DorisCommittable.java | 2 +-
.../org/apache/doris/flink/sink/DorisSink.java | 33 +-
.../apache/doris/flink/sink/HttpPutBuilder.java | 5 +
.../java/org/apache/doris/flink/sink/HttpUtil.java | 20 +
.../org/apache/doris/flink/sink/ResponseUtil.java | 7 +
.../flink/sink/copy/BackoffAndRetryUtils.java | 69 ++++
.../doris/flink/sink/copy/BatchStageLoad.java | 412 +++++++++++++++++++++
.../CopyCommittableSerializer.java} | 34 +-
.../doris/flink/sink/copy/CopySQLBuilder.java | 96 +++++
.../DorisCopyCommittable.java} | 37 +-
.../doris/flink/sink/copy/DorisCopyCommitter.java | 166 +++++++++
.../DorisCopyWriter.java} | 104 ++++--
.../doris/flink/sink/copy/HttpPostBuilder.java | 71 ++++
.../copy/models/BaseResponse.java} | 26 +-
.../copy/models/CopyIntoResp.java} | 26 +-
.../doris/flink/sink/writer/LabelGenerator.java | 10 +
.../apache/doris/flink/tools/cdc/DatabaseSync.java | 4 +
.../flink/sink/copy/TestDorisCopyCommitter.java | 109 ++++++
20 files changed, 1135 insertions(+), 115 deletions(-)
copy
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/{StreamLoadException.java
=> CopyLoadException.java} (80%)
copy
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/{writer/EventType.java
=> DorisAbstractCommittable.java} (89%)
create mode 100644
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BackoffAndRetryUtils.java
create mode 100644
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java
copy
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/{DorisCommittableSerializer.java
=> copy/CopyCommittableSerializer.java} (58%)
create mode 100644
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopySQLBuilder.java
copy
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/{DorisCommittable.java
=> copy/DorisCopyCommittable.java} (65%)
create mode 100644
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommitter.java
copy
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/{batch/DorisBatchWriter.java
=> copy/DorisCopyWriter.java} (68%)
create mode 100644
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/HttpPostBuilder.java
copy
flink-doris-connector/src/main/java/org/apache/doris/flink/{rest/models/Backend.java
=> sink/copy/models/BaseResponse.java} (70%)
copy
flink-doris-connector/src/main/java/org/apache/doris/flink/{rest/models/Backend.java
=> sink/copy/models/CopyIntoResp.java} (69%)
create mode 100644
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/copy/TestDorisCopyCommitter.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
