@Internal public class GetShardListResult extends Object
KinesisProxyInterface.getShardList(Map)
call.Constructor and Description |
---|
GetShardListResult() |
Modifier and Type | Method and Description |
---|---|
void |
addRetrievedShardsToStream(String stream,
List<StreamShardHandle> retrievedShards) |
void |
addRetrievedShardToStream(String stream,
StreamShardHandle retrievedShard) |
StreamShardHandle |
getLastSeenShardOfStream(String stream) |
List<StreamShardHandle> |
getRetrievedShardListOfStream(String stream) |
Set<String> |
getStreamsWithRetrievedShards() |
boolean |
hasRetrievedShards() |
public void addRetrievedShardToStream(String stream, StreamShardHandle retrievedShard)
public void addRetrievedShardsToStream(String stream, List<StreamShardHandle> retrievedShards)
public List<StreamShardHandle> getRetrievedShardListOfStream(String stream)
public StreamShardHandle getLastSeenShardOfStream(String stream)
public boolean hasRetrievedShards()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.