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 ae49b46 [hotfix] Fix checkstyle violations in TaskManagerLocation
add 07c8918 [FLINK-19586] Extract 'TestSink' from 'WriterOperatorTestBase'
add e90e8cc [FLINK-19586] Add committer operators for STREAMING mode for
new Sink API
add ec04072 [FLINK-19586] Add global committer operator for STREAMING
mode for new Sink API
No new revisions were added by this update.
Summary of changes:
.../sink/AbstractStreamingCommitterOperator.java | 163 ++++++++++++
.../AbstractStreamingCommitterOperatorFactory.java | 48 ++++
.../sink/GlobalStreamingCommitterOperator.java | 103 ++++++++
.../GlobalStreamingCommitterOperatorFactory.java | 57 ++++
.../operators/sink/StreamingCommitterOperator.java | 75 ++++++
.../sink/StreamingCommitterOperatorFactory.java | 58 +++++
.../operators/sink/StreamingCommitterState.java | 71 +++++
.../sink/StreamingCommitterStateSerializer.java | 111 ++++++++
.../sink/GlobalStreamingCommitterOperatorTest.java | 252 ++++++++++++++++++
.../sink/StreamingCommitterOperatorTest.java | 216 ++++++++++++++++
.../StreamingCommitterStateSerializerTest.java | 76 ++++++
.../sink/StreamingCommitterStateTest.java | 53 ++++
.../streaming/runtime/operators/sink/TestSink.java | 286 +++++++++++++++++++++
.../flink/streaming/util/TestHarnessUtil.java | 27 ++
14 files changed, 1596 insertions(+)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/AbstractStreamingCommitterOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/AbstractStreamingCommitterOperatorFactory.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/GlobalStreamingCommitterOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/GlobalStreamingCommitterOperatorFactory.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/StreamingCommitterOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/StreamingCommitterOperatorFactory.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/StreamingCommitterState.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/StreamingCommitterStateSerializer.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/GlobalStreamingCommitterOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/StreamingCommitterOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/StreamingCommitterStateSerializerTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/StreamingCommitterStateTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/TestSink.java
