This is an automated email from the ASF dual-hosted git repository.
fcsaky pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git
from 373be6f [FLINK-37687] Introduce support for Flink 2.0 in
flink-connector-aws
add 68acdbd [FLINK-36296] Add support for incremental shard discovery for
DynamoDB Streams Source
No new revisions were added by this update.
Summary of changes:
.../connector/aws/util/AWSClientUtilTest.java | 6 +-
.../sink/DynamoDbTypeInformedElementConverter.java | 5 +-
.../dynamodb/source/DynamoDbStreamsSource.java | 45 ++++++-----
.../DynamodbStreamsSourceConfigConstants.java | 4 +
.../DynamoDbStreamsSourceEnumerator.java | 26 ++++--
.../enumerator/event/SplitsFinishedEvent.java | 15 ++--
.../event/SplitsFinishedEventContext.java | 52 ++++++++++++
.../source/enumerator/tracker/SplitTracker.java | 4 +
.../source/proxy/DynamoDbStreamsProxy.java | 43 ++++++++++
.../dynamodb/source/proxy/StreamProxy.java | 10 +++
.../source/reader/DynamoDbStreamsSourceReader.java | 50 +++++++++---
.../PollingDynamoDbStreamsShardSplitReader.java | 92 +++++++++++++++++++---
.../source/split/DynamoDbStreamsShardSplit.java | 40 +++++++++-
.../split/DynamoDbStreamsShardSplitSerializer.java | 49 +++++++++++-
.../split/DynamoDbStreamsShardSplitState.java | 10 +++
.../DynamoDbStreamsSourceEnumeratorTest.java | 36 ++++++---
.../source/proxy/DynamoDbStreamsProxyTest.java | 86 +++++++++++++++++++-
.../reader/DynamoDbStreamsSourceReaderTest.java | 16 +++-
...PollingDynamoDbStreamsShardSplitReaderTest.java | 16 +++-
.../DynamoDbStreamsShardSplitSerializerTest.java | 14 ++++
.../source/util/DynamoDbStreamsClientProvider.java | 29 +++++++
.../source/util/DynamoDbStreamsProxyProvider.java | 23 ++++++
.../connector/dynamodb/source/util/TestUtil.java | 35 ++++++++
pom.xml | 2 +-
24 files changed, 627 insertions(+), 81 deletions(-)
create mode 100644
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/event/SplitsFinishedEventContext.java
