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.