org.springframework.cloud.stream.binder.kinesis.adapter

Class SpringDynamoDBAdapterClient

java.lang.Object

com.amazonaws.services.kinesis.AbstractAmazonKinesis

com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient

org.springframework.cloud.stream.binder.kinesis.adapter.SpringDynamoDBAdapterClient

All Implemented Interfaces:

com.amazonaws.services.kinesis.AmazonKinesis

public class SpringDynamoDBAdapterClient
extends com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient

This is Spring Cloud DynamoDB Adapter to be able to support ListShards operations.

Since:

2.0.3

Author:

Asiel Caballero

See Also:

ListShards

Nested Class Summary

Nested classes/interfaces inherited from class com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient

com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient.SkipRecordsBehavior

Field Summary

Fields inherited from class com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient

GET_RECORDS_LIMIT

Fields inherited from interface com.amazonaws.services.kinesis.AmazonKinesis

ENDPOINT_PREFIX

Constructor Summary

Constructors

Constructor and Description
SpringDynamoDBAdapterClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams amazonDynamoDBStreams)

Method Summary

Modifier and Type	Method and Description
com.amazonaws.services.kinesis.model.ListShardsResult	listShards(com.amazonaws.services.kinesis.model.ListShardsRequest request) List shards for a DynamoDB Stream using its DescribeStream API, as they don't support ListShards operations.

Methods inherited from class com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient

addTagsToStream, createStream, createStream, decreaseStreamRetentionPeriod, deleteStream, deleteStream, describeStream, describeStream, describeStream, describeStream, getCachedResponseMetadata, getRecords, getShardIterator, getShardIterator, getShardIterator, getSkipRecordsBehavior, increaseStreamRetentionPeriod, listStreams, listStreams, listStreams, listStreams, listTagsForStream, mergeShards, mergeShards, putRecord, putRecord, putRecord, putRecords, removeTagsFromStream, setEndpoint, setGenerateRecordBytes, setRegion, setSkipRecordsBehavior, shutdown, splitShard, splitShard

Methods inherited from class com.amazonaws.services.kinesis.AbstractAmazonKinesis

deregisterStreamConsumer, describeLimits, describeStreamConsumer, describeStreamSummary, disableEnhancedMonitoring, enableEnhancedMonitoring, listStreamConsumers, registerStreamConsumer, startStreamEncryption, stopStreamEncryption, updateShardCount, waiters

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SpringDynamoDBAdapterClient

public SpringDynamoDBAdapterClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams amazonDynamoDBStreams)

Method Detail

listShards

public com.amazonaws.services.kinesis.model.ListShardsResult listShards(com.amazonaws.services.kinesis.model.ListShardsRequest request)

List shards for a DynamoDB Stream using its DescribeStream API, as they don't support ListShards operations. Returns the result adapted to use the AmazonKinesis model.

Specified by:

listShards in interface com.amazonaws.services.kinesis.AmazonKinesis

Overrides:

listShards in class com.amazonaws.services.kinesis.AbstractAmazonKinesis

Parameters:

request - Container for the necessary parameters to execute the ListShards service method

Returns:

The response from the DescribeStream service method, adapted for use with the AmazonKinesis model