public class HadoopGroupByGate extends HadoopGroupGate
GroupingSpliceGate.DelegatedTuple
closure, collector
groupComparators, groupHasher, grouping, groupSortTuple, groupTuple, keyBuilder, keyEntry, keyFields, keyTuple, nullsAreNotEqual, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields, valueTuple
flowProcess, incomingScopes, outgoingScopes, role, splice
Constructor and Description |
---|
HadoopGroupByGate(FlowProcess flowProcess,
GroupBy groupBy,
IORole role) |
Modifier and Type | Method and Description |
---|---|
protected HadoopGroupByClosure |
createClosure() |
protected OutputCollector |
createOutputCollector() |
protected Tuple |
unwrapGrouping(Tuple key) |
protected void |
wrapGroupingAndCollect(Duct previous,
int ordinal,
Tuple valuesTuple,
Tuple groupKey) |
accept, bind, complete, prepare, receive, start
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators, initialize
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, receiveFirst
public HadoopGroupByGate(FlowProcess flowProcess, GroupBy groupBy, IORole role)
protected HadoopGroupByClosure createClosure()
createClosure
in class HadoopGroupGate
protected void wrapGroupingAndCollect(Duct previous, int ordinal, Tuple valuesTuple, Tuple groupKey) throws java.io.IOException
wrapGroupingAndCollect
in class HadoopGroupGate
java.io.IOException
protected Tuple unwrapGrouping(Tuple key)
unwrapGrouping
in class HadoopGroupGate
protected OutputCollector createOutputCollector()
createOutputCollector
in class HadoopGroupGate
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.