public class TezMergeGate extends cascading.flow.stream.element.SpliceGate<cascading.tuple.TupleEntry,cascading.tuple.TupleEntry> 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 java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> |
logicalOutputs |
Constructor and Description |
---|
TezMergeGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Splice splice,
cascading.flow.stream.graph.IORole role,
java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs) |
TezMergeGate(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 |
---|---|
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) |
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
protected java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs
protected cascading.util.SortedListMultiMap<java.lang.Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs
public TezMergeGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.Splice splice, cascading.flow.stream.graph.IORole role, java.util.Collection<org.apache.tez.runtime.api.LogicalOutput> logicalOutputs)
public TezMergeGate(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.SpliceGate<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.Duct<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.