You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fp...@apache.org on 2021/11/29 16:05:54 UTC
[flink] branch master updated (cbedff7 -> 84f9baa)

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%)