com.basho.riak.client.query

Class ReducePhase

java.lang.Object

com.basho.riak.client.query.MapPhase

com.basho.riak.client.query.ReducePhase

All Implemented Interfaces:

MapReducePhase

public class ReducePhase
extends MapPhase

A reduce phase of a MapReduce job spec. Just a tag class.

Author:

russell

Nested Class Summary

Nested classes/interfaces inherited from interface com.basho.riak.client.query.MapReducePhase

MapReducePhase.PhaseType

Constructor Summary

Constructors

Constructor and Description
ReducePhase(Function phaseFunction)
ReducePhase(Function phaseFunction, boolean keep)
ReducePhase(Function phaseFunction, Object arg)
ReducePhase(Function phaseFunction, Object arg, boolean keepResult) Create a Reduce Phase

Method Summary

Methods

Modifier and Type	Method and Description
MapReducePhase.PhaseType	getType() The PhaseType of this MapReducePhase implementation.

Methods inherited from class com.basho.riak.client.query.MapPhase

getArg, getPhaseFunction, isKeep, map

Methods inherited from class java.lang.Object

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

Constructor Detail

ReducePhase

public ReducePhase(Function phaseFunction,
           Object arg,
           boolean keepResult)

Create a Reduce Phase

Parameters:

phaseFunction -

arg -

keepResult -

ReducePhase

public ReducePhase(Function phaseFunction,
           Object arg)

Parameters:

phaseFunction -

arg -

ReducePhase

public ReducePhase(Function phaseFunction,
           boolean keep)

Parameters:

phaseFunction -

keep -

ReducePhase

public ReducePhase(Function phaseFunction)

Parameters:

phaseFunction -

Method Detail

getType

public MapReducePhase.PhaseType getType()

Description copied from interface: MapReducePhase

The PhaseType of this MapReducePhase implementation.

Specified by:

getType in interface MapReducePhase

Overrides:

getType in class MapPhase

Returns:

a PhaseType.