This is an automated email from the ASF dual-hosted git repository.
hong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e98915a5f53 [FLINK-37638][clients] Avoid duplicate call on
`getEffectiveConfiguration`
add 2ee862e48d0 [FLINK-37298] Added Pluggable Components for BatchStrategy
& BufferWrapper in AsyncSinkWriter. (#26274)
No new revisions were added by this update.
Summary of changes:
.../base/sink/writer/AsyncSinkWriter.java | 108 +++++++------
.../flink/connector/base/sink/writer/Batch.java | 90 +++++++++++
.../connector/base/sink/writer/BatchCreator.java | 68 ++++++++
.../base/sink/writer/BufferedRequestState.java | 6 +
.../base/sink/writer/DequeRequestBuffer.java | 100 ++++++++++++
.../connector/base/sink/writer/RequestBuffer.java | 107 ++++++++++++
.../base/sink/writer/SimpleBatchCreator.java | 79 +++++++++
.../base/sink/writer/AsyncSinkWriterTest.java | 116 +++++++++++++
.../connector/base/sink/writer/BatchTest.java | 34 ++--
.../base/sink/writer/DequeRequestBufferTest.java | 111 +++++++++++++
.../base/sink/writer/SimpleBatchCreatorTest.java | 180 +++++++++++++++++++++
11 files changed, 932 insertions(+), 67 deletions(-)
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/Batch.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/BatchCreator.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/DequeRequestBuffer.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/RequestBuffer.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/SimpleBatchCreator.java
copy
flink-table/flink-table-common/src/test/java/org/apache/flink/table/api/constraints/UniqueConstraintTest.java
=>
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/BatchTest.java
(53%)
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/DequeRequestBufferTest.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/SimpleBatchCreatorTest.java
