Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BATCH_SIZE |
static boolean |
DEFAULT_STOP_ONERROR |
static int |
DEFAULT_THREAD_COUNT |
Constructor and Description |
---|
FlowImpl() |
Modifier and Type | Method and Description |
---|---|
Flow |
deserialize(com.fasterxml.jackson.databind.JsonNode json)
Deserialize a json response and applies it to this flow
|
int |
getBatchSize()
Returns flow batch size
|
java.lang.String |
getDescription()
Returns flow description
|
java.lang.String |
getName()
Returns the name of the flow
|
com.fasterxml.jackson.databind.JsonNode |
getOptions()
Returns flow options as JsonNode
|
java.util.Map<java.lang.String,java.lang.Object> |
getOverrideOptions()
Gets the overridden options that were set at java runtime
|
java.util.Map<java.lang.String,java.lang.Object> |
getOverrideStepConfig()
Gets the overridden options that were set at java runtime
|
Step |
getStep(java.lang.String stepKey)
Gets the step specified by string key
|
Step |
getStepById(java.lang.String stepKey)
Deprecated.
|
java.util.Map<java.lang.String,Step> |
getSteps()
Returns a map of Steps
|
int |
getThreadCount()
Returns flow thread count
|
int |
getVersion()
Gets version
|
boolean |
isStopOnError()
Returns the value for stop on error flag
|
void |
setBatchSize(int batchSize)
Set flow batch size
|
void |
setDescription(java.lang.String description)
Sets flow description
|
void |
setName(java.lang.String flowName)
Sets the name of the flow
|
void |
setOptions(com.fasterxml.jackson.databind.JsonNode options)
Sets flow options
|
void |
setOverrideOptions(java.util.Map<java.lang.String,java.lang.Object> overrideOptions)
Sets the overridden options for the flow to use at java runtime
|
void |
setOverrideStepConfig(java.util.Map<java.lang.String,java.lang.Object> overrideStepConfig)
Sets the overridden step configs to use at java runtime
|
void |
setSteps(java.util.Map<java.lang.String,Step> steps)
Sets the steps to the flow model
|
void |
setStopOnError(boolean stopOnError)
If set stops the flow on error
|
void |
setThreadCount(int threadCount)
Sets flow thread count
|
void |
setVersion(int version)
Sets version
|
public static final int DEFAULT_BATCH_SIZE
public static final int DEFAULT_THREAD_COUNT
public static final boolean DEFAULT_STOP_ONERROR
public java.util.Map<java.lang.String,java.lang.Object> getOverrideStepConfig()
Flow
getOverrideStepConfig
in interface Flow
public void setOverrideStepConfig(java.util.Map<java.lang.String,java.lang.Object> overrideStepConfig)
Flow
setOverrideStepConfig
in interface Flow
overrideStepConfig
- a map object that represents the json step runner config that are to be used at runtimepublic void setOverrideOptions(java.util.Map<java.lang.String,java.lang.Object> overrideOptions)
Flow
setOverrideOptions
in interface Flow
overrideOptions
- a map object that represents the json flow options that are to be used at runtimepublic java.util.Map<java.lang.String,java.lang.Object> getOverrideOptions()
Flow
getOverrideOptions
in interface Flow
public java.lang.String getName()
Flow
public void setName(java.lang.String flowName)
Flow
public java.lang.String getDescription()
Flow
getDescription
in interface Flow
public void setDescription(java.lang.String description)
Flow
setDescription
in interface Flow
description
- a flow descriptionpublic int getBatchSize()
Flow
getBatchSize
in interface Flow
public void setBatchSize(int batchSize)
Flow
setBatchSize
in interface Flow
batchSize
- flow batch sizepublic int getThreadCount()
Flow
getThreadCount
in interface Flow
public void setThreadCount(int threadCount)
Flow
setThreadCount
in interface Flow
threadCount
- thread count for flowpublic com.fasterxml.jackson.databind.JsonNode getOptions()
Flow
getOptions
in interface Flow
public void setOptions(com.fasterxml.jackson.databind.JsonNode options)
Flow
setOptions
in interface Flow
options
- - a options nodepublic java.util.Map<java.lang.String,Step> getSteps()
Flow
public void setSteps(java.util.Map<java.lang.String,Step> steps)
Flow
public Step getStep(java.lang.String stepKey)
Flow
public void setStopOnError(boolean stopOnError)
Flow
setStopOnError
in interface Flow
stopOnError
- boolean flag to stop on errorpublic boolean isStopOnError()
Flow
isStopOnError
in interface Flow
public int getVersion()
Flow
getVersion
in interface Flow
public void setVersion(int version)
Flow
setVersion
in interface Flow
version
- version for the flowpublic Flow deserialize(com.fasterxml.jackson.databind.JsonNode json)
Flow
deserialize
in interface Flow
json
- - the JsonNode you want deserialize@Deprecated public Step getStepById(java.lang.String stepKey)
Flow
getStepById
in interface Flow
stepKey
- id for the step