程序包 dev.tinyflow.core.chain

类 ChainState

java.lang.Object

dev.tinyflow.core.chain.ChainState

所有已实现的接口:

Serializable

public class ChainState
extends Object
implements Serializable

另请参阅:

• 序列化表格

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	ChainState.ChainDeserializer
static class	ChainState.ChainSerializer

字段概要

字段

修饰符和类型	字段	说明
private String	chainDefinitionId
private long	computeCost
private Map<String,Object>	environment
private ExceptionSummary	error
private Map<String,Object>	executeResult
private String	instanceId
private ConcurrentHashMap<String,Object>	memory
private String	message
private String	parentInstanceId
private ChainStatus	status
private List<Parameter>	suspendForParameters
private Set<String>	suspendNodeIds
private List<String>	triggerEdgeIds
private List<String>	triggerNodeIds
private List<String>	uncheckedEdgeIds
private List<String>	uncheckedNodeIds
private long	version

构造器概要

构造器

构造器	说明
ChainState()

方法概要

修饰符和类型	方法	说明
void	addComputeCost(Long value)
void	addSuspendForParameter(Parameter parameter)
void	addSuspendForParameters(List<Parameter> parameters)
void	addSuspendNodeId(String nodeId)
void	addTriggerEdgeId(String edgeId)
void	addTriggerNodeId(String nodeId)
void	addUncheckedEdgeId(String edgeId)
void	addUncheckedNodeId(String nodeId)
static ChainState	fromJSON(String jsonString)
String	getChainDefinitionId()
Long	getComputeCost()
Map<String,Object>	getEnvironment()
Map<String,Object>	getEnvMap()
ExceptionSummary	getError()
Map<String,Object>	getExecuteResult()
String	getInstanceId()
ConcurrentHashMap<String,Object>	getMemory()
String	getMessage()
Map<String,Object>	getNodeExecuteResult(String nodeId)
String	getParentInstanceId()
Map<String,Object>	getStartParameters()
ChainStatus	getStatus()
List<Parameter>	getSuspendForParameters()
Set<String>	getSuspendNodeIds()
List<String>	getTriggerEdgeIds()
List<String>	getTriggerNodeIds()
List<String>	getUncheckedEdgeIds()
List<String>	getUncheckedNodeIds()
long	getVersion()
private boolean	isNullOrBlank(Object value)
void	removeSuspendNodeId(String nodeId)
boolean	removeUncheckedEdgeId(String edgeId)
boolean	removeUncheckedNodeId(String nodeId)
void	reset()
Map<String,Object>	resolveParameters(Node node)
Map<String,Object>	resolveParameters(Node node, List<? extends Parameter> parameters)
Map<String,Object>	resolveParameters(Node node, List<? extends Parameter> parameters, Map<String,Object> formatArgs)
Map<String,Object>	resolveParameters(Node node, List<? extends Parameter> parameters, Map<String,Object> formatArgs, boolean ignoreRequired)
Object	resolveValue(String path)
void	setChainDefinitionId(String chainDefinitionId)
void	setComputeCost(long computeCost)
void	setComputeCost(Long computeCost)
void	setEnvironment(Map<String,Object> environment)
void	setError(ExceptionSummary error)
void	setExecuteResult(Map<String,Object> executeResult)
void	setInstanceId(String instanceId)
void	setMemory(ConcurrentHashMap<String,Object> memory)
void	setMessage(String message)
void	setParentInstanceId(String parentInstanceId)
void	setStatus(ChainStatus status)
void	setSuspendForParameters(List<Parameter> suspendForParameters)
void	setSuspendNodeIds(Set<String> suspendNodeIds)
void	setTriggerEdgeIds(List<String> triggerEdgeIds)
void	setTriggerNodeIds(List<String> triggerNodeIds)
void	setUncheckedEdgeIds(List<String> uncheckedEdgeIds)
void	setUncheckedNodeIds(List<String> uncheckedNodeIds)
void	setVersion(long version)
String	toJSON()
String	toString()

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

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

字段详细资料

instanceId

private String instanceId

parentInstanceId

private String parentInstanceId

chainDefinitionId

private String chainDefinitionId

memory

private ConcurrentHashMap<String,Object> memory

executeResult

private Map<String,Object> executeResult

environment

private Map<String,Object> environment

triggerEdgeIds

private List<String> triggerEdgeIds

triggerNodeIds

private List<String> triggerNodeIds

uncheckedEdgeIds

private List<String> uncheckedEdgeIds

uncheckedNodeIds

private List<String> uncheckedNodeIds

computeCost

private long computeCost

suspendNodeIds

private Set<String> suspendNodeIds

suspendForParameters

private List<Parameter> suspendForParameters

status

private ChainStatus status

message

private String message

error

private ExceptionSummary error

version

private long version

构造器详细资料

ChainState

public ChainState()

方法详细资料

getInstanceId

public String getInstanceId()

setInstanceId

public void setInstanceId(String instanceId)

getParentInstanceId

public String getParentInstanceId()

setParentInstanceId

public void setParentInstanceId(String parentInstanceId)

getChainDefinitionId

public String getChainDefinitionId()

setChainDefinitionId

public void setChainDefinitionId(String chainDefinitionId)

getMemory

public ConcurrentHashMap<String,Object> getMemory()

setMemory

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

getExecuteResult

public Map<String,Object> getExecuteResult()

setExecuteResult

public void setExecuteResult(Map<String,Object> executeResult)

getEnvironment

public Map<String,Object> getEnvironment()

setEnvironment

public void setEnvironment(Map<String,Object> environment)

getTriggerEdgeIds

public List<String> getTriggerEdgeIds()

setTriggerEdgeIds

public void setTriggerEdgeIds(List<String> triggerEdgeIds)

addTriggerEdgeId

public void addTriggerEdgeId(String edgeId)

getTriggerNodeIds

public List<String> getTriggerNodeIds()

setTriggerNodeIds

public void setTriggerNodeIds(List<String> triggerNodeIds)

addTriggerNodeId

public void addTriggerNodeId(String nodeId)

getUncheckedEdgeIds

public List<String> getUncheckedEdgeIds()

setUncheckedEdgeIds

public void setUncheckedEdgeIds(List<String> uncheckedEdgeIds)

addUncheckedEdgeId

public void addUncheckedEdgeId(String edgeId)

removeUncheckedEdgeId

public boolean removeUncheckedEdgeId(String edgeId)

getUncheckedNodeIds

public List<String> getUncheckedNodeIds()

setUncheckedNodeIds

public void setUncheckedNodeIds(List<String> uncheckedNodeIds)

addUncheckedNodeId

public void addUncheckedNodeId(String nodeId)

removeUncheckedNodeId

public boolean removeUncheckedNodeId(String nodeId)

getComputeCost

public Long getComputeCost()

setComputeCost

public void setComputeCost(Long computeCost)

setComputeCost

public void setComputeCost(long computeCost)

getSuspendNodeIds

public Set<String> getSuspendNodeIds()

setSuspendNodeIds

public void setSuspendNodeIds(Set<String> suspendNodeIds)

addSuspendNodeId

public void addSuspendNodeId(String nodeId)

removeSuspendNodeId

public void removeSuspendNodeId(String nodeId)

getSuspendForParameters

public List<Parameter> getSuspendForParameters()

setSuspendForParameters

public void setSuspendForParameters(List<Parameter> suspendForParameters)

addSuspendForParameter

public void addSuspendForParameter(Parameter parameter)

addSuspendForParameters

public void addSuspendForParameters(List<Parameter> parameters)

getStatus

public ChainStatus getStatus()

setStatus

public void setStatus(ChainStatus status)

getMessage

public String getMessage()

setMessage

public void setMessage(String message)

getError

public ExceptionSummary getError()

setError

public void setError(ExceptionSummary error)

getVersion

public long getVersion()

setVersion

public void setVersion(long version)

fromJSON

public static ChainState fromJSON(String jsonString)

toJSON

public String toJSON()

reset

public void reset()

addComputeCost

public void addComputeCost(Long value)

getNodeExecuteResult

public Map<String,Object> getNodeExecuteResult(String nodeId)

resolveValue

public Object resolveValue(String path)

resolveParameters

public Map<String,Object> resolveParameters(Node node)

resolveParameters

public Map<String,Object> resolveParameters(Node node,
 List<? extends Parameter> parameters)

resolveParameters

public Map<String,Object> resolveParameters(Node node,
 List<? extends Parameter> parameters,
 Map<String,Object> formatArgs)

isNullOrBlank

private boolean isNullOrBlank(Object value)

getEnvMap

public Map<String,Object> getEnvMap()

getStartParameters

public Map<String,Object> getStartParameters()

resolveParameters

public Map<String,Object> resolveParameters(Node node,
 List<? extends Parameter> parameters,
 Map<String,Object> formatArgs,
 boolean ignoreRequired)

toString

public String toString()

覆盖:

toString 在类中 Object