cascading.pipe.joiner
Class BufferJoin
java.lang.Object
cascading.pipe.joiner.BaseJoiner
cascading.pipe.joiner.BufferJoin
- All Implemented Interfaces:
- DeclaresResults, Joiner, Serializable
public class BufferJoin
- extends BaseJoiner
Class BufferJoiner notifies the Cascading planner that the next Buffer
instance
will implement a custom join strategy.
Internally this class simply returns Fields.NONE
from BaseJoiner.getFieldDeclaration()
as a flag to
the planner.
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BufferJoin
public BufferJoin()
getIterator
public Iterator<Tuple> getIterator(JoinerClosure closure)
- Description copied from interface:
Joiner
- Returns an iterator that joins the given CoGroupClosure co-groups.
- Parameters:
closure
- of type GroupClosure
- Returns:
- an iterator
numJoins
public int numJoins()
- Description copied from interface:
Joiner
- Returns the number of joins this instance can handle. A value of -1 denotes there is no limit.
- Returns:
- an int
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.