public class TezGroupByClosure extends HadoopGroupByClosure
grouping, values
flowProcess, joinFields, valueFields
Constructor and Description |
---|
TezGroupByClosure(FlowProcess flowProcess,
Fields[] groupingFields,
Fields[] valueFields) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Iterator<Tuple> |
getValueIterator(int pos) |
getGrouping, getGroupTuple, getIterator, isEmpty, makeIterator, reset, size
getFlowProcess, getJoinFields, getValueFields, isSelfJoin
public TezGroupByClosure(FlowProcess flowProcess, Fields[] groupingFields, Fields[] valueFields)
protected java.util.Iterator<Tuple> getValueIterator(int pos)
getValueIterator
in class HadoopGroupByClosure
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.