This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 14fdd13b632 [FLINK-25537] [JUnit5 Migration] Module: flink-core 
with,Package: core (#24881)
     add f0b01277dd2 [FLINK-35378][FLIP-453] Promote Unified Sink API V2 to 
Public and Deprecate SinkFunction. This closes #24805

No new revisions were added by this update.

Summary of changes:
 .../18509c9e-3250-4c52-91b9-11ccefc85db1                 |  9 +++++++++
 .../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5                 | 16 ++++++++--------
 .../org/apache/flink/api/connector/sink2/Committer.java  |  6 +++---
 .../flink/api/connector/sink2/CommitterInitContext.java  |  4 ++--
 .../flink/api/connector/sink2/CommittingSinkWriter.java  |  4 ++--
 .../java/org/apache/flink/api/connector/sink2/Sink.java  |  3 ++-
 .../org/apache/flink/api/connector/sink2/SinkWriter.java |  6 +++---
 .../flink/api/connector/sink2/StatefulSinkWriter.java    |  4 ++--
 .../flink/api/connector/sink2/SupportsCommitter.java     |  4 ++--
 .../flink/api/connector/sink2/SupportsWriterState.java   |  3 ++-
 .../flink/api/connector/sink2/WriterInitContext.java     |  6 ++----
 .../streaming/api/functions/sink/DiscardingSink.java     |  3 +++
 .../streaming/api/functions/sink/PrintSinkFunction.java  |  3 +++
 .../streaming/api/functions/sink/RichSinkFunction.java   |  8 +++++++-
 .../flink/streaming/api/functions/sink/SinkFunction.java |  3 +++
 .../streaming/api/functions/sink/SocketClientSink.java   |  3 +++
 .../api/functions/sink/TwoPhaseCommitSinkFunction.java   |  3 +++
 pom.xml                                                  |  5 +++++
 18 files changed, 64 insertions(+), 29 deletions(-)

Reply via email to