This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c740f92 [FLINK-24160][tests] Use FS checkpoint storage in
PartiallyFinishedSourcesITCase
new 2e33a40 [FLINK-24041][connectors] First draft of API, Add DynamoDB
sink to verify API, Add Firehose sink, Refactor to use FLIP-143: Unified Sink
API, Increase robustness for flush, Add license header, Update JavaDoc comments
new 271a346 [FLINK-24041][connectors] Added unit and integration tests
for the generic sink implementation. Corrected an inconsistency that led to
prepareCommit() not fully flushing the entire contents of the buffer at
checkpoint time, removed catching of RuntimeExceptions in concrete
implementations, added @PublicEvolving to classes, rearranged cosmetics of
classes, corrected spelling errors, changed tests to reflect removal of
RuntimeException, added checks on the parameters passe [...]
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/connector/base/sink/AsyncSinkBase.java | 71 ++++
.../base/sink/writer/AsyncSinkWriter.java | 238 ++++++++++++++
.../base/sink/writer/ElementConverter.java} | 22 +-
.../src/main/resources/log4j2.properties | 0
.../connector/base/sink/ArrayListAsyncSink.java | 72 ++++
.../connector/base/sink/ArrayListDestination.java | 43 +++
.../connector/base/sink/AsyncSinkBaseITCase.java | 62 ++++
.../base/sink/writer/AsyncSinkWriterTest.java | 362 +++++++++++++++++++++
8 files changed, 858 insertions(+), 12 deletions(-)
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBase.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java
copy
flink-connectors/{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcStatementBuilder.java
=>
flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/ElementConverter.java}
(57%)
copy
{flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources
=> flink-connectors/flink-connector-base}/src/main/resources/log4j2.properties
(100%)
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/ArrayListAsyncSink.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/ArrayListDestination.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTest.java
