public abstract class SpliceGate<Incoming,Outgoing> extends Gate<Incoming,Outgoing> implements ElementDuct, Collapsing
Modifier and Type | Field and Description |
---|---|
protected FlowProcess |
flowProcess |
protected java.util.List<Scope> |
incomingScopes |
protected java.util.List<Scope> |
outgoingScopes |
protected IORole |
role |
protected Splice |
splice |
Constructor and Description |
---|
SpliceGate(FlowProcess flowProcess,
Splice splice) |
SpliceGate(FlowProcess flowProcess,
Splice splice,
IORole role) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object object) |
java.util.Set<java.lang.String> |
getBranchNames() |
FlowElement |
getFlowElement() |
java.util.List<Scope> |
getIncomingScopes() |
java.util.List<Scope> |
getOutgoingScopes() |
Splice |
getSplice() |
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 |
initialize()
Called immediately after bind
|
void |
setBranchNames(java.util.Set<java.lang.String> branchNames) |
void |
setTrapHandler(TrapHandler trapHandler) |
java.lang.String |
toString() |
bind, cleanup, complete, getNext, getNextFor, prepare, receive, receiveFirst, start
protected final FlowProcess flowProcess
protected final java.util.List<Scope> incomingScopes
protected final java.util.List<Scope> outgoingScopes
public SpliceGate(FlowProcess flowProcess, Splice splice)
public SpliceGate(FlowProcess flowProcess, Splice splice, IORole role)
protected void handleReThrowableException(java.lang.String message, java.lang.Throwable throwable)
protected void handleException(java.lang.Throwable exception, TupleEntry tupleEntry)
public void initialize()
Duct
initialize
in class Duct<Incoming,Outgoing>
public void setBranchNames(java.util.Set<java.lang.String> branchNames)
setBranchNames
in interface ElementDuct
public java.util.Set<java.lang.String> getBranchNames()
getBranchNames
in interface ElementDuct
public void setTrapHandler(TrapHandler trapHandler)
setTrapHandler
in interface ElementDuct
public boolean hasTrapHandler()
hasTrapHandler
in interface ElementDuct
public FlowElement getFlowElement()
getFlowElement
in interface ElementDuct
public java.util.List<Scope> getOutgoingScopes()
getOutgoingScopes
in interface ElementDuct
public java.util.List<Scope> getIncomingScopes()
getIncomingScopes
in interface ElementDuct
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.