| Package | Description |
|---|---|
| com.basho.riak.client.api.commands.mapreduce |
Commands for Map-Reduce in Riak.
|
| com.basho.riak.client.core.operations |
| Modifier and Type | Method and Description |
|---|---|
protected MapReduce.Response |
MapReduce.convertResponse(FutureOperation<MapReduceOperation.Response,?,BinaryValue> request,
MapReduceOperation.Response coreResponse) |
| Modifier and Type | Method and Description |
|---|---|
protected MapReduce.Response |
MapReduce.convertResponse(FutureOperation<MapReduceOperation.Response,?,BinaryValue> request,
MapReduceOperation.Response coreResponse) |
protected MapReduce.Response |
MapReduce.createResponse(int timeout,
StreamingRiakFuture<MapReduceOperation.Response,BinaryValue> coreFuture) |
| Modifier and Type | Method and Description |
|---|---|
protected MapReduceOperation.Response |
MapReduceOperation.convert(List<RiakKvPB.RpbMapRedResp> rawResponse) |
protected MapReduceOperation.Response |
MapReduceOperation.processStreamingChunk(RiakKvPB.RpbMapRedResp rawResponseChunk) |
Copyright © 2016. All rights reserved.