com.basho.riak.pbc

Class MapReduceResponseSource

java.lang.Object

com.basho.riak.pbc.MapReduceResponseSource

All Implemented Interfaces:

Iterable<MapReduceResponse>

public class MapReduceResponseSource
extends Object

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

Field Summary

Fields

Modifier and Type	Field and Description
protected com.basho.riak.pbc.RiakConnection	conn

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
void	close()
boolean	hasNext()
boolean	isClosed()
Iterator<T>	iterator()
MapReduceResponse	next()
static org.json.JSONArray	readAllResults(MapReduceResponseSource response) Buffer the full set of results into a JSONArray

Methods inherited from class java.lang.Object

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

Field Detail

conn

protected com.basho.riak.pbc.RiakConnection conn

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

Throws:

IOException

next

public MapReduceResponse next()
                       throws IOException

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

close

public void close()

isClosed

public boolean isClosed()

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>