public class MixedJoin extends BaseJoiner
Iterator
that will iterate over a given
Joiner
and return tuples that represent a join as defined by the given boolean array.
So if joining three streams, boolean []{true,false,false}
will result in a 'inner', 'outer', 'outer' join.
Joins perform based on the equality of the join keys. In the case of null values, Java treats two
null values as equivalent. SQL does not treat null values as equal. To produce SQL like results in a given
join, a new Comparator
will need to be used on the joined values to prevent null from
equaling null. As a convenience, see the NullNotEquivalentComparator
class.Modifier and Type | Class and Description |
---|---|
class |
MixedJoin.JoinIterator |
Modifier and Type | Field and Description |
---|---|
static boolean |
INNER
Field INNER
|
static boolean |
OUTER
Field OUTER
|
Constructor and Description |
---|
MixedJoin(boolean[] asInner)
Constructor MixedJoin creates a new MixedJoin instance.
|
MixedJoin(Fields fieldDeclaration,
boolean[] asInner) |
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 static boolean INNER
public static boolean OUTER
@ConstructorProperties(value="asInner") public MixedJoin(boolean[] asInner)
asInner
- of type boolean[]@ConstructorProperties(value={"fieldDeclaration","asInner"}) public MixedJoin(Fields fieldDeclaration, boolean[] asInner)
public int numJoins()
Joiner
Joiner.numJoins()
public Iterator<Tuple> getIterator(JoinerClosure closure)
Joiner
closure
- of type GroupClosureCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.