public class BufferJoin extends BaseJoiner
Buffer
instance
will implement a custom join strategy.
Internally this class simply returns Fields.NONE
from BaseJoiner.getFieldDeclaration()
as a flag to
the planner.Constructor and Description |
---|
BufferJoin() |
Modifier and Type | Method and Description |
---|---|
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.
|
getFieldDeclaration
public BufferJoin()
public Iterator<Tuple> getIterator(JoinerClosure closure)
Joiner
closure
- of type GroupClosureCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.