This is an automated email from the ASF dual-hosted git repository.
zykkk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
from 52cc84e [Feature] add stream load batch write (#168)
add 382e1f3 add sink.ignore-update-before (#169)
No new revisions were added by this update.
Summary of changes:
flink-doris-connector/pom.xml | 2 +-
.../doris/flink/cfg/DorisExecutionOptions.java | 30 ++++++++---
.../sink/writer/JsonDebeziumSchemaSerializer.java | 59 +++++++++++++++++++---
.../doris/flink/table/DorisConfigOptions.java | 7 +++
.../flink/table/DorisDynamicTableFactory.java | 3 ++
.../doris/flink/table/DorisDynamicTableSink.java | 12 ++---
.../apache/doris/flink/tools/cdc/DatabaseSync.java | 5 +-
.../writer/TestJsonDebeziumSchemaSerializer.java | 22 ++++++++
8 files changed, 118 insertions(+), 22 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
