Uses of Class
org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer

Packages that use ShardConsumer

Package	Description
org.apache.flink.streaming.connectors.kinesis.internals

Uses of ShardConsumer in org.apache.flink.streaming.connectors.kinesis.internals

Methods in org.apache.flink.streaming.connectors.kinesis.internals that return ShardConsumer

Modifier and Type	Method and Description
protected ShardConsumer<T>	KinesisDataFetcher.createShardConsumer(Integer subscribedShardStateIndex, StreamShardHandle subscribedShard, SequenceNumber lastSequenceNum, ShardMetricsReporter shardMetricsReporter, KinesisDeserializationSchema<T> shardDeserializer) Create a new shard consumer.
protected ShardConsumer<T>	DynamoDBStreamsDataFetcher.createShardConsumer(Integer subscribedShardStateIndex, StreamShardHandle handle, SequenceNumber lastSeqNum, ShardMetricsReporter shardMetricsReporter, KinesisDeserializationSchema<T> shardDeserializer) Create a new DynamoDB streams shard consumer.