Package | Description |
---|---|
com.basho.riak.client.api.commands.indexes |
Commands for performing secondary index (2i) queries in Riak.
|
com.basho.riak.client.api.commands.kv |
Commands for storing, fetching, and deleting objects.
|
com.basho.riak.client.core.operations |
Modifier and Type | Field and Description |
---|---|
protected SecondaryIndexQueryOperation.Response |
SecondaryIndexQuery.Response.coreResponse |
Modifier and Type | Method and Description |
---|---|
protected S |
SecondaryIndexQuery.convertResponse(FutureOperation<SecondaryIndexQueryOperation.Response,?,SecondaryIndexQueryOperation.Query> request,
SecondaryIndexQueryOperation.Response coreResponse) |
R |
SecondaryIndexQuery.GatherableResponseCreator.createResponse(Namespace queryLocation,
SecondaryIndexQueryOperation.Response coreResponse,
SecondaryIndexQuery.IndexConverter<T> converter) |
Modifier and Type | Method and Description |
---|---|
protected S |
SecondaryIndexQuery.convertResponse(FutureOperation<SecondaryIndexQueryOperation.Response,?,SecondaryIndexQueryOperation.Query> request,
SecondaryIndexQueryOperation.Response coreResponse) |
protected S |
SecondaryIndexQuery.createResponse(int timeout,
StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture) |
R |
SecondaryIndexQuery.StreamableResponseCreator.createResponse(Namespace queryLocation,
SecondaryIndexQuery.IndexConverter<T> converter,
int timeout,
StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture) |
Constructor and Description |
---|
Response(Namespace queryLocation,
SecondaryIndexQueryOperation.Response coreResponse,
SecondaryIndexQuery.IndexConverter<BigInteger> converter) |
Response(Namespace queryLocation,
SecondaryIndexQueryOperation.Response coreResponse,
SecondaryIndexQuery.IndexConverter<BinaryValue> converter) |
Response(Namespace queryLocation,
SecondaryIndexQueryOperation.Response coreResponse,
SecondaryIndexQuery.IndexConverter<Long> converter) |
Response(Namespace queryLocation,
SecondaryIndexQueryOperation.Response coreResponse,
SecondaryIndexQuery.IndexConverter<String> converter) |
Response(Namespace queryLocation,
SecondaryIndexQueryOperation.Response coreResponse,
SecondaryIndexQuery.IndexConverter<T> converter) |
Constructor and Description |
---|
Response(Namespace queryLocation,
SecondaryIndexQuery.IndexConverter<T> converter,
int timeout,
StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture) |
Constructor and Description |
---|
Response(Namespace queryLocation,
SecondaryIndexQueryOperation.Response coreResponse,
SecondaryIndexQuery.IndexConverter<BinaryValue> converter) |
Constructor and Description |
---|
Response(Namespace queryLocation,
SecondaryIndexQuery.IndexConverter<BinaryValue> converter,
int timeout,
StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture) |
Modifier and Type | Method and Description |
---|---|
protected SecondaryIndexQueryOperation.Response |
SecondaryIndexQueryOperation.convert(List<Object> rawResponse) |
protected SecondaryIndexQueryOperation.Response |
SecondaryIndexQueryOperation.processStreamingChunk(Object rawResponseChunk) |
Copyright © 2016. All rights reserved.