public class TezBoundaryStage extends cascading.flow.stream.element.BoundaryStage<cascading.tuple.TupleEntry,cascading.tuple.TupleEntry> implements cascading.flow.stream.element.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 |
Constructor and Description |
---|
TezBoundaryStage(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Boundary boundary,
cascading.flow.stream.graph.IORole role,
java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs) |
TezBoundaryStage(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Boundary boundary,
cascading.flow.stream.graph.IORole role,
org.apache.tez.runtime.api.LogicalInput logicalInput) |
Modifier and Type | Method and Description |
---|---|
void |
bind(cascading.flow.stream.graph.StreamGraph streamGraph) |
void |
complete(cascading.flow.stream.duct.Duct previous) |
protected OutputCollector |
createOutputCollector() |
void |
initialize() |
protected java.lang.Throwable |
map() |
void |
prepare() |
void |
receive(cascading.flow.stream.duct.Duct previous,
int ordinal,
cascading.tuple.TupleEntry incomingEntry) |
void |
run(java.lang.Object input) |
void |
start(cascading.flow.stream.duct.Duct previous) |
getBoundary, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, handleException, handleReThrowableException, hasTrapHandler, setBranchNames, setTrapHandler
protected java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs
protected org.apache.tez.runtime.api.LogicalInput logicalInput
public TezBoundaryStage(cascading.flow.FlowProcess flowProcess, cascading.pipe.Boundary boundary, cascading.flow.stream.graph.IORole role, java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs)
public TezBoundaryStage(cascading.flow.FlowProcess flowProcess, cascading.pipe.Boundary boundary, cascading.flow.stream.graph.IORole role, org.apache.tez.runtime.api.LogicalInput logicalInput)
public void initialize()
initialize
in class cascading.flow.stream.element.BoundaryStage<cascading.tuple.TupleEntry,cascading.tuple.TupleEntry>
public void bind(cascading.flow.stream.graph.StreamGraph streamGraph)
bind
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.tuple.TupleEntry>
public void prepare()
prepare
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.tuple.TupleEntry>
public void start(cascading.flow.stream.duct.Duct previous)
start
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.tuple.TupleEntry>
public void receive(cascading.flow.stream.duct.Duct previous, int ordinal, cascading.tuple.TupleEntry incomingEntry)
receive
in class cascading.flow.stream.duct.Stage<cascading.tuple.TupleEntry,cascading.tuple.TupleEntry>
public void complete(cascading.flow.stream.duct.Duct previous)
complete
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,cascading.tuple.TupleEntry>
public void run(java.lang.Object input) throws java.lang.Throwable
run
in interface cascading.flow.stream.element.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.