public abstract class HadoopGroupGate extends cascading.flow.stream.element.GroupingSpliceGate
Modifier and Type | Field and Description |
---|---|
protected HadoopGroupByClosure |
closure |
protected OutputCollector |
collector |
groupComparators, groupHasher, grouping, groupSortTuple, groupTuple, keyBuilder, keyEntry, keyFields, keyTuple, nullsAreNotEqual, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields, valueTuple
Constructor and Description |
---|
HadoopGroupGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Splice splice,
cascading.flow.stream.graph.IORole role) |
Modifier and Type | Method and Description |
---|---|
void |
accept(cascading.tuple.Tuple key,
java.util.Iterator<cascading.tuple.Tuple>[] values) |
void |
bind(cascading.flow.stream.graph.StreamGraph streamGraph) |
void |
complete(cascading.flow.stream.duct.Duct previous) |
protected abstract HadoopGroupByClosure |
createClosure() |
protected abstract OutputCollector |
createOutputCollector() |
void |
prepare() |
void |
receive(cascading.flow.stream.duct.Duct previous,
int ordinal,
cascading.tuple.TupleEntry incomingEntry) |
void |
start(cascading.flow.stream.duct.Duct previous) |
protected abstract cascading.tuple.Tuple |
unwrapGrouping(cascading.tuple.Tuple key) |
protected abstract void |
wrapGroupingAndCollect(cascading.flow.stream.duct.Duct previous,
int ordinal,
cascading.tuple.Tuple valuesTuple,
cascading.tuple.Tuple groupKey) |
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators, initialize
protected HadoopGroupByClosure closure
protected OutputCollector collector
public HadoopGroupGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.Splice splice, cascading.flow.stream.graph.IORole role)
public void bind(cascading.flow.stream.graph.StreamGraph streamGraph)
bind
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.duct.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
public void prepare()
prepare
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.duct.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
protected abstract OutputCollector createOutputCollector()
public void start(cascading.flow.stream.duct.Duct previous)
start
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.duct.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
public void receive(cascading.flow.stream.duct.Duct previous, int ordinal, cascading.tuple.TupleEntry incomingEntry)
receive
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.duct.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
public void complete(cascading.flow.stream.duct.Duct previous)
complete
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.duct.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
public void accept(cascading.tuple.Tuple key, java.util.Iterator<cascading.tuple.Tuple>[] values)
protected abstract HadoopGroupByClosure createClosure()
protected abstract void wrapGroupingAndCollect(cascading.flow.stream.duct.Duct previous, int ordinal, cascading.tuple.Tuple valuesTuple, cascading.tuple.Tuple groupKey) throws java.io.IOException
java.io.IOException
protected abstract cascading.tuple.Tuple unwrapGrouping(cascading.tuple.Tuple key)
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.