| Modifier and Type | Method and Description |
|---|---|
protected RiakFuture<QueryResult,String> |
Query.executeAsync(RiakCluster cluster) |
protected RiakFuture<QueryResult,String> |
ListKeys.executeAsync(RiakCluster cluster) |
protected RiakFuture<QueryResult,String> |
Fetch.executeAsync(RiakCluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
static QueryResult |
TermToBinaryCodec.decodeTsResultResponse(byte[] response) |
| Modifier and Type | Method and Description |
|---|---|
protected QueryResult |
QueryOperation.convert(List<byte[]> responses) |
protected QueryResult |
FetchOperation.convert(List<byte[]> responses) |
protected QueryResult |
ListKeysOperation.convert(List<RiakTsPB.TsListKeysResp> rawResponses) |
| Modifier and Type | Field and Description |
|---|---|
static QueryResult |
QueryResult.EMPTY |
| Modifier and Type | Method and Description |
|---|---|
static QueryResult |
PbResultFactory.convertPbGetResp(RiakTsPB.TsGetResp response) |
static QueryResult |
PbResultFactory.convertPbListKeysResp(List<RiakTsPB.TsListKeysResp> responseChunks) |
static QueryResult |
PbResultFactory.convertPbQueryResp(RiakTsPB.TsQueryResp response) |
Copyright © 2016. All rights reserved.