public abstract class TezGroupGate extends HadoopGroupGate implements cascading.flow.stream.element.InputSource
Modifier and Type | Field and Description |
---|---|
protected cascading.util.SortedListMultiMap<java.lang.Integer,org.apache.tez.runtime.api.LogicalInput> |
logicalInputs |
protected org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput |
logicalOutput |
closure, collector
groupComparators, groupHasher, grouping, groupSortTuple, groupTuple, keyBuilder, keyEntry, keyFields, keyTuple, nullsAreNotEqual, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields, valueTuple
Constructor and Description |
---|
TezGroupGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Splice splice,
cascading.flow.stream.graph.IORole role,
org.apache.tez.runtime.api.LogicalOutput logicalOutput) |
TezGroupGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Splice splice,
cascading.flow.stream.graph.IORole role,
cascading.util.SortedListMultiMap<java.lang.Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs) |
Modifier and Type | Method and Description |
---|---|
protected OutputCollector |
createOutputCollector() |
void |
initialize() |
void |
prepare() |
protected abstract java.lang.Throwable |
reduce() |
void |
run(java.lang.Object input) |
protected void |
wrapGroupingAndCollect(cascading.flow.stream.duct.Duct previous,
int ordinal,
cascading.tuple.Tuple valuesTuple,
cascading.tuple.Tuple groupKey) |
accept, bind, complete, createClosure, receive, start, unwrapGrouping
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators
protected org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput logicalOutput
protected cascading.util.SortedListMultiMap<java.lang.Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs
public TezGroupGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.Splice splice, cascading.flow.stream.graph.IORole role, org.apache.tez.runtime.api.LogicalOutput logicalOutput)
public TezGroupGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.Splice splice, cascading.flow.stream.graph.IORole role, cascading.util.SortedListMultiMap<java.lang.Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs)
public void initialize()
initialize
in class cascading.flow.stream.element.GroupingSpliceGate
public void prepare()
prepare
in class HadoopGroupGate
public void run(java.lang.Object input) throws java.lang.Throwable
run
in interface cascading.flow.stream.element.InputSource
java.lang.Throwable
protected abstract java.lang.Throwable reduce() throws java.lang.Exception
java.lang.Exception
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 OutputCollector createOutputCollector()
createOutputCollector
in class HadoopGroupGate
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.