Package | Description |
---|---|
org.apache.flink.streaming.connectors.kinesis.proxy |
Modifier and Type | Method and Description |
---|---|
GetShardListResult |
DynamoDBStreamsProxy.getShardList(Map<String,String> streamNamesWithLastSeenShardIds) |
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 |
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–2021 The Apache Software Foundation. All rights reserved.