public class TezBoundaryStage extends BoundaryStage<TupleEntry,TupleEntry> implements InputSource
Modifier and Type | Field and Description |
---|---|
protected org.apache.tez.runtime.api.LogicalInput |
logicalInput |
protected java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> |
logicalOutputs |
boundary, flowProcess, incomingScopes, outgoingScopes, role
Constructor and Description |
---|
TezBoundaryStage(FlowProcess flowProcess,
Boundary boundary,
IORole role,
java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs) |
TezBoundaryStage(FlowProcess flowProcess,
Boundary boundary,
IORole role,
org.apache.tez.runtime.api.LogicalInput logicalInput) |
Modifier and Type | Method and Description |
---|---|
void |
bind(StreamGraph streamGraph) |
void |
complete(Duct previous) |
protected OutputCollector |
createOutputCollector() |
void |
initialize() |
protected java.lang.Throwable |
map() |
void |
prepare() |
void |
receive(Duct previous,
int ordinal,
TupleEntry incomingEntry) |
void |
run(java.lang.Object input) |
void |
start(Duct previous) |
getBoundary, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, handleException, handleReThrowableException, hasTrapHandler, setBranchNames, setTrapHandler
cleanup, getNext, getNextFor, receiveFirst, toString
protected java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs
protected org.apache.tez.runtime.api.LogicalInput logicalInput
public TezBoundaryStage(FlowProcess flowProcess, Boundary boundary, IORole role, java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs)
public TezBoundaryStage(FlowProcess flowProcess, Boundary boundary, IORole role, org.apache.tez.runtime.api.LogicalInput logicalInput)
public void initialize()
initialize
in class BoundaryStage<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, int ordinal, TupleEntry incomingEntry)
receive
in class Stage<TupleEntry,TupleEntry>
public void complete(Duct previous)
complete
in class Duct<TupleEntry,TupleEntry>
public void run(java.lang.Object input) throws java.lang.Throwable
run
in interface InputSource
java.lang.Throwable
protected java.lang.Throwable map() throws java.lang.Exception
java.lang.Exception
protected OutputCollector createOutputCollector()
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.