cascading.pipe.cogroup
Class InnerJoin
java.lang.Object
cascading.pipe.cogroup.InnerJoin
- All Implemented Interfaces:
- Joiner, Serializable
public class InnerJoin
- extends Object
- implements Joiner
Class InnerJoin will return an InnerJoin.JoinIterator
that will iterate over a given Joiner
and return tuples that represent
and inner join of the CoGrouper internal grouped tuple collections.
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
InnerJoin
public InnerJoin()
getIterator
public Iterator<Tuple> getIterator(GroupClosure closure)
- Description copied from interface:
Joiner
- Returns an iterator that joins the given CoGroupClosure co-groups.
- Specified by:
getIterator
in interface Joiner
- 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.
- Specified by:
numJoins
in interface Joiner
- Returns:
- an int
Copyright © 2007-2010 Concurrent, Inc. All Rights Reserved.