public class HadoopCoGroupGate extends HadoopGroupGate
closure, collector
groupComparators, groupHasher, grouping, groupSortTuple, groupTuple, keyBuilder, keyEntry, keyFields, nullsAreNotEqual, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields
Constructor and Description |
---|
HadoopCoGroupGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.CoGroup coGroup,
cascading.flow.stream.graph.IORole role) |
Modifier and Type | Method and Description |
---|---|
void |
bind(cascading.flow.stream.graph.StreamGraph streamGraph) |
protected HadoopCoGroupClosure |
createClosure() |
protected OutputCollector |
createOutputCollector() |
protected cascading.tuple.Tuple |
unwrapGrouping(cascading.tuple.Tuple key) |
protected void |
wrapGroupingAndCollect(cascading.flow.stream.duct.Duct previous,
int ordinal,
cascading.tuple.Tuple valuesTuple,
cascading.tuple.Tuple groupKey) |
accept, complete, prepare, receive, start
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators, initialize
public HadoopCoGroupGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.CoGroup coGroup, cascading.flow.stream.graph.IORole role)
public void bind(cascading.flow.stream.graph.StreamGraph streamGraph)
bind
in class HadoopGroupGate
protected HadoopCoGroupClosure createClosure()
createClosure
in class HadoopGroupGate
protected void wrapGroupingAndCollect(cascading.flow.stream.duct.Duct previous, int ordinal, cascading.tuple.Tuple valuesTuple, cascading.tuple.Tuple groupKey) throws java.io.IOException
wrapGroupingAndCollect
in class HadoopGroupGate
java.io.IOException
protected cascading.tuple.Tuple unwrapGrouping(cascading.tuple.Tuple key)
unwrapGrouping
in class HadoopGroupGate
protected OutputCollector createOutputCollector()
createOutputCollector
in class HadoopGroupGate
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.