com.basho.riak.client.api.commands.mapreduce

Class MapReduce.Response

java.lang.Object

com.basho.riak.client.api.StreamableRiakCommand.StreamableResponse<MapReduce.Response,BinaryValue>

com.basho.riak.client.api.commands.mapreduce.MapReduce.Response

All Implemented Interfaces:

Iterable<MapReduce.Response>

Enclosing class:

MapReduce

public static class MapReduce.Response
extends StreamableRiakCommand.StreamableResponse<MapReduce.Response,BinaryValue>

Response from a MapReduce command.

Field Summary

Fields inherited from class com.basho.riak.client.api.StreamableRiakCommand.StreamableResponse

chunkedResponseIterator

Constructor Summary

Constructors

Constructor and Description
Response(Map<Integer,com.fasterxml.jackson.databind.node.ArrayNode> results)

Method Summary

Modifier and Type	Method and Description
com.fasterxml.jackson.databind.node.ArrayNode	getResultForPhase(int i)
com.fasterxml.jackson.databind.node.ArrayNode	getResultsFromAllPhases()
<T> Collection<T>	getResultsFromAllPhases(Class<T> resultType)
boolean	hasResultForPhase(int i)
boolean	isStreaming() Whether the results are to be streamed back.
Iterator<MapReduce.Response>	iterator() Get an iterator over the result data.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

Response

public Response(Map<Integer,com.fasterxml.jackson.databind.node.ArrayNode> results)

Method Detail

isStreaming

public boolean isStreaming()

Description copied from class: StreamableRiakCommand.StreamableResponse

Whether the results are to be streamed back. If true, results will appear in this class's iterator. If false, they will appear in the original result collection.

Overrides:

isStreaming in class StreamableRiakCommand.StreamableResponse<MapReduce.Response,BinaryValue>

Returns:

true if the results are to be streamed.

hasResultForPhase

public boolean hasResultForPhase(int i)

getResultForPhase

public com.fasterxml.jackson.databind.node.ArrayNode getResultForPhase(int i)

getResultsFromAllPhases

public com.fasterxml.jackson.databind.node.ArrayNode getResultsFromAllPhases()

getResultsFromAllPhases

public <T> Collection<T> getResultsFromAllPhases(Class<T> resultType)

iterator

public Iterator<MapReduce.Response> iterator()

Description copied from class: StreamableRiakCommand.StreamableResponse

Get an iterator over the result data. If using the streaming API, this method will block and wait for more data if none is immediately available. It is also advisable to check Thread.isInterrupted() in environments where thread interrupts must be obeyed.

Specified by:

iterator in interface Iterable<MapReduce.Response>

Overrides:

iterator in class StreamableRiakCommand.StreamableResponse<MapReduce.Response,BinaryValue>

Returns:

an iterator over the result data.