cascading.pipe.joiner
Interface Joiner

All Superinterfaces:

Serializable

All Known Implementing Classes:

InnerJoin, LeftJoin, MixedJoin, OuterJoin, RightJoin

public interface Joiner
extends Serializable

Interface Joiner allows for custom join strategies against a HadoopCoGroupClosure.

Method Summary

Iterator<Tuple>	getIterator(JoinerClosure closure) Returns an iterator that joins the given CoGroupClosure co-groups.
int	numJoins() Returns the number of joins this instance can handle.

Method Detail

getIterator

Iterator<Tuple> getIterator(JoinerClosure closure)

Returns an iterator that joins the given CoGroupClosure co-groups.

Parameters:

closure - of type GroupClosure

Returns:

an iterator

numJoins

int numJoins()

Returns the number of joins this instance can handle. A value of -1 denotes there is no limit.

Returns:

an int