public class TezMergeGate extends SpliceGate<TupleEntry,TupleEntry> implements InputSource
Modifier and Type | Field and Description |
---|---|
protected SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> |
logicalInputs |
protected Collection<org.apache.tez.runtime.api.LogicalOutput> |
logicalOutputs |
flowProcess, incomingScopes, outgoingScopes, role, splice
Constructor and Description |
---|
TezMergeGate(FlowProcess flowProcess,
Splice splice,
IORole role,
Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs) |
TezMergeGate(FlowProcess flowProcess,
Splice splice,
IORole role,
SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs) |
Modifier and Type | Method and Description |
---|---|
void |
bind(StreamGraph streamGraph) |
void |
complete(Duct previous) |
protected OutputCollector |
createOutputCollector() |
void |
initialize() |
protected Throwable |
map() |
void |
prepare() |
void |
receive(Duct previous,
TupleEntry incomingEntry) |
void |
run(Object input) |
void |
start(Duct previous) |
getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hasTrapHandler, setBranchNames, setTrapHandler
cleanup, getNext, getNextFor, receiveFirst, toString
protected Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs
protected SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs
public TezMergeGate(FlowProcess flowProcess, Splice splice, IORole role, Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs)
public TezMergeGate(FlowProcess flowProcess, Splice splice, IORole role, SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs)
public void initialize()
initialize
in class SpliceGate<TupleEntry,TupleEntry>
public void bind(StreamGraph streamGraph)
bind
in class Duct<TupleEntry,TupleEntry>
public void prepare()
prepare
in class Duct<TupleEntry,TupleEntry>
public void start(Duct previous)
start
in class Duct<TupleEntry,TupleEntry>
public void receive(Duct previous, TupleEntry incomingEntry)
receive
in class Duct<TupleEntry,TupleEntry>
public void complete(Duct previous)
complete
in class Duct<TupleEntry,TupleEntry>
public void run(Object input) throws Throwable
run
in interface InputSource
Throwable
protected OutputCollector createOutputCollector()
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.