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

Class MapReduce.Builder<T extends MapReduce.Builder<T>>

java.lang.Object

com.basho.riak.client.api.commands.mapreduce.MapReduce.Builder<T>

Direct Known Subclasses:

BucketKeyMapReduce.Builder, BucketMapReduce.Builder, IndexMapReduce.Builder, SearchMapReduce.Builder

Enclosing class:

MapReduce

protected abstract static class MapReduce.Builder<T extends MapReduce.Builder<T>>
extends Object

Base abstract class for all MapReduce command builders.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<MapReducePhase>	phases
protected Long	timeout

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MapReduce.Builder()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract T	self()
T	timeout(long timeout) Set the operations timeout
T	withLinkPhase(String bucket, String tag) Create a Link Phase that points to bucket / tag keep will be false
T	withLinkPhase(String bucket, String tag, boolean keep) Add a Link Phase that points to bucket / tag .
T	withMapPhase(Function phaseFunction) Add a MapPhase
T	withMapPhase(Function phaseFunction, boolean keep) Add MapPhase to the query
T	withMapPhase(Function phaseFunction, Object arg) Add a MapPhase
T	withMapPhase(Function phaseFunction, Object arg, boolean keep) Add a MapPhase
T	withReducePhase(Function phaseFunction) Add a ReducePhase
T	withReducePhase(Function phaseFunction, boolean keep) Add ReducePhase to the query
T	withReducePhase(Function phaseFunction, Object arg) Add a ReducePhase
T	withReducePhase(Function phaseFunction, Object arg, boolean keep) Add a ReducePhase

Methods inherited from class java.lang.Object

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

Field Detail

phases

protected final List<MapReducePhase> phases

timeout

protected Long timeout

Constructor Detail

MapReduce.Builder

protected MapReduce.Builder()

Method Detail

timeout

public T timeout(long timeout)

Set the operations timeout

Parameters:

timeout -

Returns:

this

withMapPhase

public T withMapPhase(Function phaseFunction,
             boolean keep)

Add MapPhase to the query

Parameters:

phaseFunction - the Function

keep - keep the results and return them with the query results?

Returns:

a reference to this object.

withMapPhase

public T withMapPhase(Function phaseFunction,
             Object arg,
             boolean keep)

Add a MapPhase

Parameters:

phaseFunction - the Function

arg - an argument that will be passed to the phase verbatim (Object#toString)

keep - if the result should be returned or merely provide input for the next phase.

Returns:

a reference to this object.

withMapPhase

public T withMapPhase(Function phaseFunction,
             Object arg)

Add a MapPhase

Parameters:

phaseFunction - the Function

arg - an argument that will be passed to the phase verbatim (Object#toString)

Returns:

a reference to this object.

withMapPhase

public T withMapPhase(Function phaseFunction)

Add a MapPhase

Parameters:

phaseFunction - the Function

Returns:

a reference to this object.

withReducePhase

public T withReducePhase(Function phaseFunction,
                boolean keep)

Add ReducePhase to the query

Parameters:

phaseFunction - the Function

keep - keep the results and return them with the query results?

Returns:

a reference to this object.

withReducePhase

public T withReducePhase(Function phaseFunction,
                Object arg,
                boolean keep)

Add a ReducePhase

Parameters:

phaseFunction - the Function

arg - an argument that will be passed to the phase verbatim (Object#toString)

keep - if the result should be returned or merely provide input for the next phase.

Returns:

a reference to this object.

withReducePhase

public T withReducePhase(Function phaseFunction,
                Object arg)

Add a ReducePhase

Parameters:

phaseFunction - the Function

arg - an argument that will be passed to the phase verbatim

Returns:

a reference to this object.

withReducePhase

public T withReducePhase(Function phaseFunction)

Add a ReducePhase

Parameters:

phaseFunction -

Returns:

a reference to this object.

withLinkPhase

public T withLinkPhase(String bucket,
              String tag,
              boolean keep)

Add a Link Phase that points to bucket / tag .

Parameters:

bucket - the bucket at the end of the link (or "_" or "" for wildcard)

tag - the tag (or ("_", or "" for wildcard)

keep - to keep the result of this phase and return it at the end of the operation

Returns:

a reference to this object.

withLinkPhase

public T withLinkPhase(String bucket,
              String tag)

Create a Link Phase that points to bucket / tag keep will be false

Parameters:

bucket - the bucket at the end of the link (or "_" or "" for wildcard)

tag - the tag (or ("_", or "" for wildcard)

Returns:

a reference to this object.

self

protected abstract T self()