程序包 dev.tinyflow.core.chain

类 NodeState

java.lang.Object

dev.tinyflow.core.chain.NodeState

所有已实现的接口:

Serializable

public class NodeState
extends Object
implements Serializable

另请参阅:

• 序列化表格

字段概要

字段

修饰符和类型	字段	说明
private String	chainInstanceId
(专用程序包) ExceptionSummary	error
private AtomicInteger	executeCount
private List<String>	executeEdgeIds
private int	loopCount
protected ConcurrentHashMap<String,Object>	memory
private String	nodeId
private int	retryCount
protected NodeStatus	status
private AtomicInteger	triggerCount
private List<String>	triggerEdgeIds
private long	version

构造器概要

构造器

构造器	说明
NodeState()

方法概要

修饰符和类型	方法	说明
void	addMemory(String key, Object value)
String	getChainInstanceId()
ExceptionSummary	getError()
AtomicInteger	getExecuteCount()
List<String>	getExecuteEdgeIds()
String	getLastExecuteEdgeId()
int	getLoopCount()
ConcurrentHashMap<String,Object>	getMemory()
<T> T	getMemoryOrDefault(String key, T defaultValue)
String	getNodeId()
int	getRetryCount()
NodeStatus	getStatus()
AtomicInteger	getTriggerCount()
List<String>	getTriggerEdgeIds()
long	getVersion()
boolean	isUpstreamFullyExecuted()
void	recordExecute(String fromEdgeId)
void	recordTrigger(String fromEdgeId)
void	setChainInstanceId(String chainInstanceId)
void	setError(ExceptionSummary error)
void	setExecuteCount(AtomicInteger executeCount)
void	setExecuteEdgeIds(List<String> executeEdgeIds)
void	setLoopCount(int loopCount)
void	setMemory(ConcurrentHashMap<String,Object> memory)
void	setNodeId(String nodeId)
void	setRetryCount(int retryCount)
void	setStatus(NodeStatus status)
void	setTriggerCount(AtomicInteger triggerCount)
void	setTriggerEdgeIds(List<String> triggerEdgeIds)
void	setVersion(long version)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

nodeId

private String nodeId

chainInstanceId

private String chainInstanceId

memory

protected ConcurrentHashMap<String,Object> memory

status

protected NodeStatus status

retryCount

private int retryCount

loopCount

private int loopCount

triggerCount

private AtomicInteger triggerCount

triggerEdgeIds

private List<String> triggerEdgeIds

executeCount

private AtomicInteger executeCount

executeEdgeIds

private List<String> executeEdgeIds

error

ExceptionSummary error

version

private long version

构造器详细资料

NodeState

public NodeState()

方法详细资料

getNodeId

public String getNodeId()

setNodeId

public void setNodeId(String nodeId)

getChainInstanceId

public String getChainInstanceId()

setChainInstanceId

public void setChainInstanceId(String chainInstanceId)

getMemory

public ConcurrentHashMap<String,Object> getMemory()

setMemory

public void setMemory(ConcurrentHashMap<String,Object> memory)

addMemory

public void addMemory(String key,
 Object value)

getMemoryOrDefault

public <T> T getMemoryOrDefault(String key,
 T defaultValue)

getStatus

public NodeStatus getStatus()

getRetryCount

public int getRetryCount()

setRetryCount

public void setRetryCount(int retryCount)

getLoopCount

public int getLoopCount()

setLoopCount

public void setLoopCount(int loopCount)

getTriggerCount

public AtomicInteger getTriggerCount()

setTriggerCount

public void setTriggerCount(AtomicInteger triggerCount)

getTriggerEdgeIds

public List<String> getTriggerEdgeIds()

setTriggerEdgeIds

public void setTriggerEdgeIds(List<String> triggerEdgeIds)

getExecuteCount

public AtomicInteger getExecuteCount()

setExecuteCount

public void setExecuteCount(AtomicInteger executeCount)

getExecuteEdgeIds

public List<String> getExecuteEdgeIds()

setExecuteEdgeIds

public void setExecuteEdgeIds(List<String> executeEdgeIds)

getError

public ExceptionSummary getError()

setError

public void setError(ExceptionSummary error)

getVersion

public long getVersion()

setVersion

public void setVersion(long version)

isUpstreamFullyExecuted

public boolean isUpstreamFullyExecuted()

recordTrigger

public void recordTrigger(String fromEdgeId)

recordExecute

public void recordExecute(String fromEdgeId)

setStatus

public void setStatus(NodeStatus status)

getLastExecuteEdgeId

public String getLastExecuteEdgeId()