cascading.pipe.cogroup
Class OuterJoin

java.lang.Object
  extended by cascading.pipe.cogroup.OuterJoin
All Implemented Interfaces:
Joiner, Serializable

public class OuterJoin
extends Object
implements Joiner

Class OuterJoin will return an OuterJoin.JoinIterator that will iterate over a given Joiner and return tuples that represent and outer join of the CoGrouper internal grouped tuple collections.

See Also:
Serialized Form

Nested Class Summary
protected static class OuterJoin.JoinIterator
           
 
Constructor Summary
OuterJoin()
           
 
Method Summary
 Iterator<Tuple> getIterator(GroupClosure closure)
          Returns an iterator that joins the given CoGroupClosure co-groups.
 int numJoins()
          Returns the number of joins this instance can handle.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

OuterJoin

public OuterJoin()
Method Detail

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.