Package org.apache.flink.streaming.connectors.kinesis.model

Class Summary

Class	Description
DynamoDBStreamsShardHandle	DynamoDB streams shard handle format and utilities.
KinesisStreamShard	Deprecated Will be remove in a future version in favor of StreamShardHandle.
KinesisStreamShardState	A wrapper class that bundles a StreamShardHandle with its last processed sequence number.
SequenceNumber	A serializable representation of a Kinesis record's sequence number.
StreamShardHandle	A wrapper class around the information provided along with streamName and Shard, with some extra utility methods to determine whether or not a shard is closed and whether or not the shard is a result of parent shard splits or merges.
StreamShardMetadata	A serializable representation of a AWS Kinesis Stream shard.
StreamShardMetadata.EquivalenceWrapper	An equivalence wrapper that only checks for the stream name and shard id for equality.

Enum Summary

Enum	Description
SentinelSequenceNumber	Special flag values for sequence numbers in shards to indicate special positions.