public class ListKeysOperation extends PBFutureOperation<QueryResult,RiakTsPB.TsListKeysResp,String>
Modifier and Type | Class and Description |
---|---|
static class |
ListKeysOperation.Builder |
reqBuilder, reqMessageCode
Modifier and Type | Method and Description |
---|---|
protected QueryResult |
convert(List<RiakTsPB.TsListKeysResp> rawResponses) |
protected boolean |
done(RiakTsPB.TsListKeysResp message)
Detect when the streaming operation is finished
|
String |
getQueryInfo()
Returns information related to the operation performed.
|
createChannelMessage, decode
addListener, await, await, cancel, cause, channelMessage, checkAndGetSingleResponse, get, get, getNow, isCancelled, isDone, isSuccess, processBatchMessage, processMessage, removeListener, setComplete, setResponse
protected QueryResult convert(List<RiakTsPB.TsListKeysResp> rawResponses)
convert
in class FutureOperation<QueryResult,RiakTsPB.TsListKeysResp,String>
public String getQueryInfo()
RiakFuture
Useful in async operations when you want to know what operation this future refers to.
getQueryInfo
in interface RiakFuture<QueryResult,String>
getQueryInfo
in class FutureOperation<QueryResult,RiakTsPB.TsListKeysResp,String>
protected boolean done(RiakTsPB.TsListKeysResp message)
FutureOperation
done
in class FutureOperation<QueryResult,RiakTsPB.TsListKeysResp,String>
message
- raw messageCopyright © 2016. All rights reserved.