public class TezGroupByClosure extends HadoopGroupByClosure
grouping, values
Constructor and Description |
---|
TezGroupByClosure(cascading.flow.FlowProcess flowProcess,
cascading.tuple.Fields[] groupingFields,
cascading.tuple.Fields[] valueFields) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Iterator<cascading.tuple.Tuple> |
getValueIterator(int pos) |
getGrouping, getGroupTuple, getIterator, isEmpty, makeIterator, reset, size
public TezGroupByClosure(cascading.flow.FlowProcess flowProcess, cascading.tuple.Fields[] groupingFields, cascading.tuple.Fields[] valueFields)
protected java.util.Iterator<cascading.tuple.Tuple> getValueIterator(int pos)
getValueIterator
in class HadoopGroupByClosure
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.