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