public class HadoopCoGroupClosure extends HadoopGroupByClosure
Modifier and Type | Class and Description |
---|---|
static class |
HadoopCoGroupClosure.Spill |
Modifier and Type | Field and Description |
---|---|
protected java.util.Collection<cascading.tuple.Tuple>[] |
collections
Field groups
|
protected int |
numSelfJoins |
grouping, values
Constructor and Description |
---|
HadoopCoGroupClosure(cascading.flow.FlowProcess flowProcess,
int numSelfJoins,
cascading.tuple.Fields[] groupingFields,
cascading.tuple.Fields[] valueFields) |
Modifier and Type | Method and Description |
---|---|
protected void |
build() |
protected void |
clearGroups() |
java.util.Iterator<cascading.tuple.Tuple> |
createIterator(cascading.tuple.io.IndexTuple current,
java.util.Iterator<cascading.tuple.io.IndexTuple> values) |
protected java.util.Collection<cascading.tuple.Tuple> |
createTupleCollection(cascading.tuple.Fields joinField) |
cascading.tuple.Tuple |
getGroupTuple(cascading.tuple.Tuple keysTuple) |
java.util.Iterator<cascading.tuple.Tuple> |
getIterator(int pos) |
protected void |
initLists() |
boolean |
isEmpty(int pos) |
void |
reset(cascading.tuple.Tuple grouping,
java.util.Iterator<cascading.tuple.Tuple>[] values) |
int |
size() |
getGrouping, getValueIterator, makeIterator
protected java.util.Collection<cascading.tuple.Tuple>[] collections
protected final int numSelfJoins
public HadoopCoGroupClosure(cascading.flow.FlowProcess flowProcess, int numSelfJoins, cascading.tuple.Fields[] groupingFields, cascading.tuple.Fields[] valueFields)
public int size()
size
in class HadoopGroupByClosure
public java.util.Iterator<cascading.tuple.Tuple> getIterator(int pos)
getIterator
in class HadoopGroupByClosure
public cascading.tuple.Tuple getGroupTuple(cascading.tuple.Tuple keysTuple)
getGroupTuple
in class HadoopGroupByClosure
public boolean isEmpty(int pos)
isEmpty
in class HadoopGroupByClosure
public void reset(cascading.tuple.Tuple grouping, java.util.Iterator<cascading.tuple.Tuple>[] values)
reset
in class HadoopGroupByClosure
protected void build()
protected void clearGroups()
protected void initLists()
protected java.util.Collection<cascading.tuple.Tuple> createTupleCollection(cascading.tuple.Fields joinField)
public java.util.Iterator<cascading.tuple.Tuple> createIterator(cascading.tuple.io.IndexTuple current, java.util.Iterator<cascading.tuple.io.IndexTuple> values)
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.