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