com.basho.riak.client.query

Class LinkPhase

java.lang.Object

com.basho.riak.client.query.LinkPhase

All Implemented Interfaces:

MapReducePhase

public class LinkPhase
extends Object
implements MapReducePhase

MapReducePhase implementation that models a Link Phase

Author:

russell

See Also:

MapReduce, MapPhase, ReducePhase

Nested Class Summary

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

MapReducePhase.PhaseType

Constructor Summary

Constructors

Constructor and Description
LinkPhase(String bucket, String tag) Create a Link Phase that points to bucket / tag keep will be false
LinkPhase(String bucket, String tag, boolean keep) Create a Link Phase that points to bucket / tag .

Method Summary

Methods

Modifier and Type	Method and Description
String	getBucket() The bucket for this link phase
String	getTag() The tag for this link phase
MapReducePhase.PhaseType	getType() The PhaseType of this MapReducePhase implementation.
Boolean	isKeep() Keep the result or just use as input to the next phase?

Methods inherited from class java.lang.Object

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

Constructor Detail

LinkPhase

public LinkPhase(String bucket,
         String tag,
         boolean keep)

Create 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

LinkPhase

public LinkPhase(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)

Method Detail

getBucket

public String getBucket()

The bucket for this link phase

Returns:

the bucket

getTag

public String getTag()

The tag for this link phase

Returns:

the tag

isKeep

public Boolean isKeep()

Keep the result or just use as input to the next phase?

Specified by:

isKeep in interface MapReducePhase

Returns:

whether the result is kept or just passed to the next phase.

getType

public MapReducePhase.PhaseType getType()

Description copied from interface: MapReducePhase

The PhaseType of this MapReducePhase implementation.

Specified by:

getType in interface MapReducePhase

Returns:

a PhaseType.