This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ec04072 [FLINK-19586] Add global committer operator for STREAMING
mode for new Sink API
add 8dba1a8 [FLINK-19696] Add committer operator for BATCH mode for the
new sink API
No new revisions were added by this update.
Summary of changes:
...erOperator.java => BatchCommitterOperator.java} | 50 ++++-----
...ory.java => BatchCommitterOperatorFactory.java} | 38 +++++--
.../sink/BatchGlobalCommitterOperator.java | 77 ++++++++++++++
...va => BatchGlobalCommitterOperatorFactory.java} | 38 ++++---
.../operators/sink/BatchCommitterOperatorTest.java | 111 ++++++++++++++++++++
.../sink/BatchGlobalCommitterOperatorTest.java | 114 +++++++++++++++++++++
6 files changed, 379 insertions(+), 49 deletions(-)
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{StreamingCommitterOperator.java
=> BatchCommitterOperator.java} (55%)
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{AbstractStreamingCommitterOperatorFactory.java
=> BatchCommitterOperatorFactory.java} (58%)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/BatchGlobalCommitterOperator.java
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{GlobalStreamingCommitterOperatorFactory.java
=> BatchGlobalCommitterOperatorFactory.java} (53%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/BatchCommitterOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/BatchGlobalCommitterOperatorTest.java
