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 0d7d8c8 [FLINK-19861][docs][table] Improve functions document which
are not deterministic
add 34d0a9c [FLINK-19833] Rename Sink API Writer interface to SinkWriter
add 926e1bc [FLINK-19760] Sink API: Make the `GlobalCommitter` not extend
the `Committer`
add d3fdc17 [FLINK-19841] Sink API: Rename
GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator
No new revisions were added by this update.
Summary of changes:
.../flink/api/connector/sink/GlobalCommitter.java | 2 +-
.../org/apache/flink/api/connector/sink/Sink.java | 10 +++----
.../sink/{Writer.java => SinkWriter.java} | 6 ++--
.../api/transformations/SinkTransformation.java | 7 +++--
...erator.java => AbstractSinkWriterOperator.java} | 34 +++++++++++-----------
...java => AbstractSinkWriterOperatorFactory.java} | 14 ++++-----
...erator.java => StatefulSinkWriterOperator.java} | 26 ++++++++---------
...java => StatefulSinkWriterOperatorFactory.java} | 20 ++++++-------
...rator.java => StatelessSinkWriterOperator.java} | 16 +++++-----
...ava => StatelessSinkWriterOperatorFactory.java} | 18 ++++++------
....java => StreamingGlobalCommitterOperator.java} | 4 +--
...> StreamingGlobalCommitterOperatorFactory.java} | 10 +++----
.../translators/SinkTransformationTranslator.java | 10 +++----
.../graph/SinkTransformationTranslatorTest.java | 8 ++---
...stBase.java => SinkWriterOperatorTestBase.java} | 24 +++++++--------
...st.java => StatefulSinkWriterOperatorTest.java} | 18 ++++++------
...t.java => StatelessSinkWriterOperatorTest.java} | 12 ++++----
...a => StreamingGlobalCommitterOperatorTest.java} | 6 ++--
.../streaming/runtime/operators/sink/TestSink.java | 18 ++++++------
19 files changed, 132 insertions(+), 131 deletions(-)
rename
flink-core/src/main/java/org/apache/flink/api/connector/sink/{Writer.java =>
SinkWriter.java} (89%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{AbstractWriterOperator.java
=> AbstractSinkWriterOperator.java} (79%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{AbstractWriterOperatorFactory.java
=> AbstractSinkWriterOperatorFactory.java} (76%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{StatefulWriterOperator.java
=> StatefulSinkWriterOperator.java} (76%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{StatefulWriterOperatorFactory.java
=> StatefulSinkWriterOperatorFactory.java} (64%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{StatelessWriterOperator.java
=> StatelessSinkWriterOperator.java} (71%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{StatelessWriterOperatorFactory.java
=> StatelessSinkWriterOperatorFactory.java} (68%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{GlobalStreamingCommitterOperator.java
=> StreamingGlobalCommitterOperator.java} (97%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/{GlobalStreamingCommitterOperatorFactory.java
=> StreamingGlobalCommitterOperatorFactory.java} (88%)
rename
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/{WriterOperatorTestBase.java
=> SinkWriterOperatorTestBase.java} (85%)
rename
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/{StatefulWriterOperatorTest.java
=> StatefulSinkWriterOperatorTest.java} (82%)
rename
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/{StatelessWriterOperatorTest.java
=> StatelessSinkWriterOperatorTest.java} (66%)
rename
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/{GlobalStreamingCommitterOperatorTest.java
=> StreamingGlobalCommitterOperatorTest.java} (98%)
