public class HadoopGroupByClosure extends JoinerClosure
Modifier and Type | Field and Description |
---|---|
protected Tuple |
grouping |
protected Iterator[] |
values |
flowProcess, joinFields, valueFields
Constructor and Description |
---|
HadoopGroupByClosure(FlowProcess flowProcess,
Fields[] groupingFields,
Fields[] valueFields) |
Modifier and Type | Method and Description |
---|---|
Tuple |
getGrouping() |
Tuple |
getGroupTuple(Tuple keysTuple) |
Iterator<Tuple> |
getIterator(int pos) |
protected Iterator |
getValueIterator(int pos) |
boolean |
isEmpty(int pos) |
protected Iterator<Tuple> |
makeIterator(int pos,
Iterator values) |
void |
reset(Tuple grouping,
Iterator<Tuple>[] values) |
int |
size() |
getFlowProcess, getJoinFields, getValueFields, isSelfJoin
public HadoopGroupByClosure(FlowProcess flowProcess, Fields[] groupingFields, Fields[] valueFields)
public Tuple getGrouping()
public int size()
size
in class JoinerClosure
protected Iterator getValueIterator(int pos)
public Iterator<Tuple> getIterator(int pos)
getIterator
in class JoinerClosure
public boolean isEmpty(int pos)
isEmpty
in class JoinerClosure
protected Iterator<Tuple> makeIterator(int pos, Iterator values)
public Tuple getGroupTuple(Tuple keysTuple)
getGroupTuple
in class JoinerClosure
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.