Package | Description |
---|---|
org.apache.flink.streaming.connectors.kinesis.internals | |
org.apache.flink.streaming.connectors.kinesis.model |
Modifier and Type | Method and Description |
---|---|
static StreamShardMetadata |
KinesisDataFetcher.convertToStreamShardMetadata(StreamShardHandle streamShardHandle)
Utility function to convert
StreamShardHandle into StreamShardMetadata . |
Modifier and Type | Method and Description |
---|---|
HashMap<StreamShardMetadata,SequenceNumber> |
KinesisDataFetcher.snapshotState()
Creates a snapshot of the current last processed sequence numbers of each subscribed shard.
|
Modifier and Type | Method and Description |
---|---|
static StreamShardHandle |
KinesisDataFetcher.convertToStreamShardHandle(StreamShardMetadata streamShardMetadata)
Utility function to convert
StreamShardMetadata into StreamShardHandle . |
Modifier and Type | Method and Description |
---|---|
static StreamShardMetadata |
KinesisStreamShard.convertToStreamShardMetadata(KinesisStreamShard kinesisStreamShard)
Deprecated.
Utility function to convert
KinesisStreamShard into the new StreamShardMetadata model. |
StreamShardMetadata |
StreamShardMetadata.EquivalenceWrapper.getShardMetadata() |
StreamShardMetadata |
KinesisStreamShardState.getStreamShardMetadata() |
Constructor and Description |
---|
EquivalenceWrapper(StreamShardMetadata shardMetadata) |
KinesisStreamShardState(StreamShardMetadata streamShardMetadata,
StreamShardHandle streamShardHandle,
SequenceNumber lastProcessedSequenceNum) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.