This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c6043a5 [FLINK-19904][docs] Document possible mismatch between Xmx
and maximum heap size metric
add 34d143f [FLINK-19736] Add SinkTransformation along with Translator
No new revisions were added by this update.
Summary of changes:
.../common/typeutils/TypeInformationTestBase.java | 7 +-
.../flink/streaming/api/datastream/DataStream.java | 18 ++
.../streaming/api/datastream/DataStreamSink.java | 27 +-
.../api/graph/SimpleTransformationTranslator.java | 25 +-
.../flink/streaming/api/graph/StreamGraph.java | 2 +-
.../streaming/api/graph/StreamGraphGenerator.java | 3 +
.../api/transformations/SinkTransformation.java | 114 ++++++++
.../operators/sink/CommittableTypeInformation.java | 119 ++++++++
.../translators/SinkTransformationTranslator.java | 304 +++++++++++++++++++++
.../streaming/util/graph/StreamGraphUtils.java | 71 +++++
...reamSourceTest.java => DataStreamSinkTest.java} | 37 +--
.../graph/SinkTransformationTranslatorTest.java | 275 +++++++++++++++++++
.../transformations/SinkTransformationTest.java | 86 ++++++
.../sink/CommittableTypeInformationTest.java | 68 +++++
.../streaming/runtime/operators/sink/TestSink.java | 58 +++-
.../flink/streaming/api/scala/DataStream.scala | 8 +
.../flink/test/streaming/runtime/SinkITCase.java | 223 +++++++++++++++
17 files changed, 1397 insertions(+), 48 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SinkTransformation.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/CommittableTypeInformation.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/graph/StreamGraphUtils.java
copy
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/datastream/{DataStreamSourceTest.java
=> DataStreamSinkTest.java} (56%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/SinkTransformationTranslatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/transformations/SinkTransformationTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/CommittableTypeInformationTest.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkITCase.java
