Package | Description |
---|---|
org.apache.flink.streaming.connectors.kinesis.proxy |
Modifier and Type | Method and Description |
---|---|
GetShardListResult |
KinesisProxyInterface.getShardList(Map<String,String> streamNamesWithLastSeenShardIds)
Get shard list of multiple Kinesis streams, ignoring the
shards of each stream before a specified last seen shard id.
|
GetShardListResult |
DynamoDBStreamsProxy.getShardList(Map<String,String> streamNamesWithLastSeenShardIds) |
GetShardListResult |
KinesisProxy.getShardList(Map<String,String> streamNamesWithLastSeenShardIds)
Get shard list of multiple Kinesis streams, ignoring the
shards of each stream before a specified last seen shard id.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.