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

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

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.