com.basho.riak.pbc

Class MapReduceResponseSource

java.lang.Object

com.basho.riak.pbc.RiakStreamClient<MapReduceResponse>

com.basho.riak.pbc.MapReduceResponseSource

All Implemented Interfaces:

Iterable<MapReduceResponse>

public class MapReduceResponseSource
extends RiakStreamClient<MapReduceResponse>

Wraps a stream of m/r responses as an iterator.

Field Summary

Fields inherited from class com.basho.riak.pbc.RiakStreamClient

conn, continuation

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MapReduceResponseSource(RiakClient client, com.basho.riak.pbc.RiakConnection conn, com.google.protobuf.ByteString contentType)

Method Summary

Methods

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

Methods inherited from class com.basho.riak.pbc.RiakStreamClient

cancel, close, getContinuation, hasContinuation, isClosed, iterator

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapReduceResponseSource

protected MapReduceResponseSource(RiakClient client,
                       com.basho.riak.pbc.RiakConnection conn,
                       com.google.protobuf.ByteString contentType)
                           throws IOException

Throws:

IOException

Method Detail

hasNext

public boolean hasNext()
                throws IOException

Specified by:

hasNext in class RiakStreamClient<MapReduceResponse>

Throws:

IOException

next

public MapReduceResponse next()
                       throws IOException

Specified by:

next in class RiakStreamClient<MapReduceResponse>

Throws:

IOException

readAllResults

public static org.json.JSONArray readAllResults(MapReduceResponseSource response)
                                         throws IOException

Buffer the full set of results into a JSONArray

Parameters:

response - the MapReduceResponseSource

Returns:

a JSONArray with all phases and all results.

Throws:

IOException