public class MapReduceResponseSource extends RiakStreamClient<MapReduceResponse>
conn, continuation
Modifier | Constructor and Description |
---|---|
protected |
MapReduceResponseSource(RiakClient client,
com.basho.riak.pbc.RiakConnection conn,
com.google.protobuf.ByteString contentType) |
Modifier and Type | Method and Description |
---|---|
boolean |
hasNext() |
MapReduceResponse |
next() |
static org.json.JSONArray |
readAllResults(MapReduceResponseSource response)
Buffer the full set of results into a JSONArray
|
close, getContinuation, hasContinuation, isClosed, iterator
protected MapReduceResponseSource(RiakClient client, com.basho.riak.pbc.RiakConnection conn, com.google.protobuf.ByteString contentType) throws IOException
IOException
public boolean hasNext() throws IOException
hasNext
in class RiakStreamClient<MapReduceResponse>
IOException
public MapReduceResponse next() throws IOException
next
in class RiakStreamClient<MapReduceResponse>
IOException
public static org.json.JSONArray readAllResults(MapReduceResponseSource response) throws IOException
response
- the MapReduceResponseSource
JSONArray
with all phases and all results.IOException
Copyright © 2013. All Rights Reserved.