public class LocalGroupByGate extends cascading.flow.stream.element.MemorySpliceGate
closure, count, keys, keyValues, numIncomingEventingPaths
groupComparators, groupHasher, grouping, groupSortTuple, groupTuple, keyBuilder, keyEntry, keyFields, keyTuple, nullsAreNotEqual, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields, valueTuple
Constructor and Description |
---|
LocalGroupByGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Splice splice) |
Modifier and Type | Method and Description |
---|---|
void |
complete(cascading.flow.stream.duct.Duct previous) |
protected boolean |
isBlockingStreamed() |
void |
prepare() |
void |
receive(cascading.flow.stream.duct.Duct previous,
int ordinal,
cascading.tuple.TupleEntry incomingEntry) |
void |
start(cascading.flow.stream.duct.Duct previous) |
bind, createDefaultNarrowBuilder, createKeySet, createKeyValuesArray, createTupleMap, initialize
cleanup, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators
public LocalGroupByGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.Splice splice)
protected boolean isBlockingStreamed()
isBlockingStreamed
in class cascading.flow.stream.element.MemorySpliceGate
public void prepare()
prepare
in class cascading.flow.stream.element.MemorySpliceGate
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>>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.