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 cbedff7 [FLINK-21407][doc][formats] Split DataSet connectors page
into different formats and create a formats sub-folder like in table api doc
add 095405d [FLINK-24596][table] Allow using unified Sinks with the
DataStreamSinkProvider
add 3a25e39 [FLINK-24596][core] Introduce SerializableFunction and unify
usages
add 84f9baa [FLINK-24596][kafka] Make passed lambdas of UpsertKafka
serializable
No new revisions were added by this update.
Summary of changes:
.../connectors/cassandra/CassandraSink.java | 2 +-
.../elasticsearch/table/KeyExtractor.java | 1 +
.../connector/jdbc/internal/JdbcOutputFormat.java | 3 +-
.../connectors/kafka/table/KafkaDynamicSink.java | 3 +-
.../connectors/kafka/table/ReducingUpsertSink.java | 6 +-
.../kafka/table/SinkBufferFlushMode.java | 3 +-
.../kafka/table/ReducingUpsertWriterTest.java | 3 +-
.../kafka/table/UpsertKafkaTableITCase.java | 96 ++++++++++++++++++++++
.../flink/util/function}/SerializableFunction.java | 9 +-
.../coordination/TestingOperatorCoordinator.java | 2 +-
.../flink/runtime/util/SerializableFunction.java | 7 +-
.../flink/streaming/api/datastream/DataStream.java | 2 +-
.../streaming/api/datastream/DataStreamSink.java | 8 +-
.../streaming/api/datastream/KeyedStream.java | 4 +-
.../api/operators/collect/CollectStreamSink.java | 8 +-
.../transformations/LegacySinkTransformation.java | 5 +-
.../LegacySinkTransformationTranslator.java | 2 +-
.../api/datastream/DataStreamSinkTest.java | 10 ++-
.../datagen/table/types/DataGeneratorMapper.java | 7 +-
.../plan/nodes/exec/batch/BatchExecLegacySink.java | 3 +-
.../nodes/exec/common/CommonExecLegacySink.java | 18 ++--
.../nodes/exec/stream/StreamExecLegacySink.java | 3 +-
.../nodes/exec/common/CommonExecSinkITCase.java | 75 +++++++++++++++--
23 files changed, 226 insertions(+), 54 deletions(-)
rename
{flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
=>
flink-core/src/main/java/org/apache/flink/util/function}/SerializableFunction.java
(77%)
