This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8f84515 [hotfix][table-planner] Ignore
LogicalRelDataTypeConverterTest temporarily
add 10f884c [FLINK-25570][tests] Ignore TypeSerializer tests for nested
serializers based on SimpleVersionedSerializerTypeSerializerProxy
add 546ee9a [FLINK-25570][streaming] Add topology extension points to
Sink V2.
No new revisions were added by this update.
Summary of changes:
.../flink/util/function/SerializableSupplier.java | 4 +-
.../api/connector/sink2/CommittableMessage.java | 29 ++--
.../sink2/CommittableMessageSerializer.java | 122 +++++++++++++++
.../sink2/CommittableMessageTypeInfo.java | 165 +++++++++++++++++++++
.../api/connector/sink2/CommittableSummary.java | 87 +++++++++++
.../connector/sink2/CommittableWithLineage.java | 58 ++++++++
.../connector/sink2/WithPostCommitTopology.java | 49 ++++++
.../api/connector/sink2/WithPreCommitTopology.java | 47 ++++++
.../api/connector/sink2/WithPreWriteTopology.java | 38 +++++
.../sink2/CommittableMessageSerializerTest.java | 64 ++++++++
.../sink2/CommittableMessageTypeInfoTest.java | 27 ++--
.../api/connector/sink2/IntegerSerializer.java | 45 ++++++
.../TypeSerializerTestCoverageTest.java | 3 +
13 files changed, 710 insertions(+), 28 deletions(-)
copy
flink-core/src/main/java/org/apache/flink/util/function/SerializableSupplier.java
=>
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/CommittableMessage.java
(54%)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/CommittableMessageSerializer.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/CommittableMessageTypeInfo.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/CommittableSummary.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/CommittableWithLineage.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPostCommitTopology.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreCommitTopology.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreWriteTopology.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/connector/sink2/CommittableMessageSerializerTest.java
copy
flink-core/src/main/java/org/apache/flink/util/function/SerializableSupplier.java
=>
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/connector/sink2/CommittableMessageTypeInfoTest.java
(54%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/connector/sink2/IntegerSerializer.java
