cascading.flow.stream
Class ElementStage<Incoming,Outgoing>
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Stage<Incoming,Outgoing>
cascading.flow.stream.ElementStage<Incoming,Outgoing>
- All Implemented Interfaces:
- ElementDuct
- Direct Known Subclasses:
- JoinStage, MergeStage, OperatorStage, SinkStage, SourceStage
public abstract class ElementStage<Incoming,Outgoing>
- extends Stage<Incoming,Outgoing>
- implements ElementDuct
Fields inherited from class cascading.flow.stream.Duct |
next |
Methods inherited from class cascading.flow.stream.Stage |
receive |
flowProcess
protected final FlowProcess flowProcess
flowElement
protected final FlowElement flowElement
branchNames
protected Set<String> branchNames
trapHandler
protected TrapHandler trapHandler
incomingScopes
protected final List<Scope> incomingScopes
outgoingScopes
protected final List<Scope> outgoingScopes
ElementStage
public ElementStage(FlowProcess flowProcess,
FlowElement flowElement)
getFlowElement
public FlowElement getFlowElement()
- Specified by:
getFlowElement
in interface ElementDuct
getIncomingScopes
public List<Scope> getIncomingScopes()
- Specified by:
getIncomingScopes
in interface ElementDuct
getBranchNames
public Set<String> getBranchNames()
- Specified by:
getBranchNames
in interface ElementDuct
setBranchNames
public void setBranchNames(Set<String> branchNames)
- Specified by:
setBranchNames
in interface ElementDuct
setTrapHandler
public void setTrapHandler(TrapHandler trapHandler)
- Specified by:
setTrapHandler
in interface ElementDuct
hasTrapHandler
public boolean hasTrapHandler()
- Specified by:
hasTrapHandler
in interface ElementDuct
addIncomingScope
public void addIncomingScope(Scope incomingScope)
- Specified by:
addIncomingScope
in interface ElementDuct
getOutgoingScopes
public List<Scope> getOutgoingScopes()
- Specified by:
getOutgoingScopes
in interface ElementDuct
addOutgoingScope
public void addOutgoingScope(Scope outgoingScope)
- Specified by:
addOutgoingScope
in interface ElementDuct
getOutgoingFields
protected Fields getOutgoingFields()
cleanup
public void cleanup()
- Overrides:
cleanup
in class Duct<Incoming,Outgoing>
handleReThrowableException
protected void handleReThrowableException(String message,
Throwable throwable)
handleException
protected void handleException(Throwable exception,
TupleEntry tupleEntry)
equals
public final boolean equals(Object object)
- Overrides:
equals
in class Object
hashCode
public final int hashCode()
- Overrides:
hashCode
in class Object
toString
public String toString()
- Overrides:
toString
in class Duct<Incoming,Outgoing>
Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.