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