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