public abstract class ElementStage<Incoming,Outgoing> extends Stage<Incoming,Outgoing> implements ElementDuct
Modifier and Type | Field and Description |
---|---|
protected java.util.Set<java.lang.String> |
branchNames |
protected FlowElement |
flowElement |
protected FlowProcess |
flowProcess |
protected java.util.List<Scope> |
incomingScopes |
protected java.util.List<Scope> |
outgoingScopes |
protected TrapHandler |
trapHandler |
Constructor and Description |
---|
ElementStage(FlowProcess flowProcess,
FlowElement flowElement) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
boolean |
equals(java.lang.Object object) |
java.util.Set<java.lang.String> |
getBranchNames() |
FlowElement |
getFlowElement() |
java.util.List<Scope> |
getIncomingScopes() |
protected Fields |
getOutgoingFields() |
java.util.List<Scope> |
getOutgoingScopes() |
protected void |
handleException(java.lang.Throwable exception,
TupleEntry tupleEntry) |
protected void |
handleReThrowableException(java.lang.String message,
java.lang.Throwable throwable) |
int |
hashCode() |
boolean |
hasTrapHandler() |
void |
setBranchNames(java.util.Set<java.lang.String> branchNames) |
void |
setTrapHandler(TrapHandler trapHandler) |
java.lang.String |
toString() |
bind, complete, getNext, getNextFor, initialize, prepare, receiveFirst, start
protected final FlowProcess flowProcess
protected final FlowElement flowElement
protected java.util.Set<java.lang.String> branchNames
protected TrapHandler trapHandler
protected final java.util.List<Scope> incomingScopes
protected final java.util.List<Scope> outgoingScopes
public ElementStage(FlowProcess flowProcess, FlowElement flowElement)
public FlowElement getFlowElement()
getFlowElement
in interface ElementDuct
public java.util.List<Scope> getIncomingScopes()
getIncomingScopes
in interface ElementDuct
public java.util.Set<java.lang.String> getBranchNames()
getBranchNames
in interface ElementDuct
public void setBranchNames(java.util.Set<java.lang.String> branchNames)
setBranchNames
in interface ElementDuct
public void setTrapHandler(TrapHandler trapHandler)
setTrapHandler
in interface ElementDuct
public boolean hasTrapHandler()
hasTrapHandler
in interface ElementDuct
public java.util.List<Scope> getOutgoingScopes()
getOutgoingScopes
in interface ElementDuct
protected Fields getOutgoingFields()
protected void handleReThrowableException(java.lang.String message, java.lang.Throwable throwable)
protected void handleException(java.lang.Throwable exception, TupleEntry tupleEntry)
public final boolean equals(java.lang.Object object)
equals
in class java.lang.Object
public final int hashCode()
hashCode
in class java.lang.Object
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.