Package com.basho.riak.client.query

Classes and interfaces for running map/reduce and link walk operations on Riak.

See: Description

Interface Summary

Interface	Description
MapReducePhase	Shared common interface for Map/Reduce phase definitions.
MapReduceResult	Defines a way to access the results of a Map/reduce query.
StreamingOperation<T>	Encapsulates a streaming Riak operation.
WalkResult	Interface defining results from a walk operation, basically an iteration of steps, each step contains some IRiakObjects.

Class Summary

Class	Description
BucketKeyMapReduce	Map/Reduce over a set of bucket/key/keydata inputs.
BucketMapReduce	Map/Reduce over a bucket, optionally add Key Filters to narrow the inputs.
IndexMapReduce	A MapReduce operation that takes a 2i index query as input
LinkPhase	MapReducePhase implementation that models a Link Phase
LinkWalk	A Link Walk operation, build the operation by adding steps, then execute.
LinkWalkStep	Used internally by LinkWalk to model a step in a link walk operation.
MapPhase	A Map Phase of a Map/Reduce job spec.
MapReduce	An operation for defining and runnig a Map/Reduce query on Riak.
MultiFetchFuture<V>	A Future for an individual fetch done as part of a MultiFetch.
NodeStats	The encapsulation of the data returned by the Riak /stats operation.
NodeStats.UndefinedStatDeserializer
ReducePhase	A reduce phase of a MapReduce job spec.
SearchMapReduce	A MapReduce operation that uses a Riak Search query as input.

Enum Summary

Enum	Description
LinkWalkStep.Accumulate	Enum for the accumulate specification of a link walk step.
MapReducePhase.PhaseType	Possible phase typess.

Exception Summary

Exception	Description
InvalidMapReduceException	Tag exception class for MapReduce classes to throw from MapReduce.validate()
NoInputsException	Thrown when a MapReduce has been configured with no inputs
RiakStreamingRuntimeException

Package com.basho.riak.client.query Description

Classes and interfaces for running map/reduce and link walk operations on Riak.

MapReduce and LinkWalk are RiakOperations. Use the IRiakClient as a factory to create the operation. Both are implemented as fluent builders. Unlike other operations they do not (yet) run with a Retrier

Please see the basho wiki on Map/Reduce and Link Walking for more details.

See Also:

IRiakClient.mapReduce(), IRiakClient.mapReduce(String), IRiakClient.walk(com.basho.riak.client.IRiakObject)