public static final class ParallelState.Builder extends Object implements InputOutputResultPathBuilder<ParallelState.Builder>, ParametersBuilder<ParallelState.Builder>, ResultSelectorBuilder<ParallelState.Builder>
ParallelState
.Buildable.Utils
public ParallelState.Builder comment(String comment)
comment
- New comment.public ParallelState.Builder branch(Branch.Builder branchBuilder)
branchBuilder
- Instance of Branch.Builder
. Note that
the Branch
object is not built until the ParallelState
is built so any modifications on the
state builder will be reflected in this object.public ParallelState.Builder branches(Branch.Builder... branchBuilders)
branchBuilders
- Instances of Branch.Builder
. Note
that the Branch
object is not built until the ParallelState
is built so any modifications on the
state builder will be reflected in this object.public ParallelState.Builder inputPath(String inputPath)
InputOutputPathBuilder
inputPath
in interface InputOutputPathBuilder<ParallelState.Builder>
inputPath
- New path value.public ParallelState.Builder resultPath(String resultPath)
ResultPathBuilder
resultPath
in interface ResultPathBuilder<ParallelState.Builder>
resultPath
- New path value.public ParallelState.Builder outputPath(String outputPath)
InputOutputPathBuilder
outputPath
in interface InputOutputPathBuilder<ParallelState.Builder>
outputPath
- New path value.public ParallelState.Builder parameters(String parameters)
ParametersBuilder
{
...
"Parameters": {
"flagged": true,
"parts": {
"first.$": "$.vals[0]",
"last3.$": "$.vals[3:]"
}
}
...
}
And suppose that the input to the state is as follows:
{
"flagged": 7,
"vals": [0, 10, 20, 30, 40, 50]
}
Then the effective input to the task will be as follows:
{
"flagged": true,
"parts": {
"first": 0,
"last3": [30, 40, 50]
}
}
parameters
in interface ParametersBuilder<ParallelState.Builder>
parameters
- Raw JSON string representing Parameters value.public ParallelState.Builder parameters(Object parameters)
ParametersBuilder
{
...
"Parameters": {
"flagged": true,
"parts": {
"first.$": "$.vals[0]",
"last3.$": "$.vals[3:]"
}
}
...
}
And suppose that the input to the state is as follows:
{
"flagged": 7,
"vals": [0, 10, 20, 30, 40, 50]
}
Then the effective input to the task will be as follows:
{
"flagged": true,
"parts": {
"first": 0,
"last3": [30, 40, 50]
}
}
parameters
in interface ParametersBuilder<ParallelState.Builder>
parameters
- Object that will be serialized into the JSON document representing this states parameters.public ParallelState.Builder resultSelector(String resultSelector)
ResultSelectorBuilder
{
...
"ResultSelector": {
"ClusterId.$": "$.output.ClusterId",
"ResourceType.$": "$.resourceType"
},
"ResultPath": "$.EMROutput"
...
}
Suppose the result of the Task is as follows:
{
...
"resourceType": "elasticmapreduce",
"output": {
"ClusterId": "AKIAIOSFODNN7EXAMPLE"
}
...
}
Then the effective result from the task will be as follows:
{
...
"EMROutput": {
"ClusterId": "AKIAIOSFODNN7EXAMPLE",
"ResourceType": "elasticmapreduce"
}
...
}
resultSelector
in interface ResultSelectorBuilder<ParallelState.Builder>
resultSelector
- Raw JSON string representing ResultSelector value.public ParallelState.Builder resultSelector(Object resultSelector)
ResultSelectorBuilder
{
...
"ResultSelector": {
"ClusterId.$": "$.output.ClusterId",
"ResourceType.$": "$.resourceType"
},
"ResultPath": "$.EMROutput"
...
}
Suppose the result of the Task is as follows:
{
...
"resourceType": "elasticmapreduce",
"output": {
"ClusterId": "AKIAIOSFODNN7EXAMPLE"
}
...
}
Then the effective result from the task will be as follows:
{
...
"EMROutput": {
"ClusterId": "AKIAIOSFODNN7EXAMPLE",
"ResourceType": "elasticmapreduce"
}
...
}
resultSelector
in interface ResultSelectorBuilder<ParallelState.Builder>
resultSelector
- Object that will be serialized into the JSON document representing this state's ResultSelector.public ParallelState.Builder transition(Transition.Builder builder)
builder
- New transition.public ParallelState.Builder retriers(Retrier.Builder... retrierBuilders)
Retrier
s to this states retries. If a single branch fails then the entire parallel state is
considered failed and eligible for retry.retrierBuilders
- Instances of Retrier.Builder
. Note
that the Retrier
object is not built until the ParallelState
is built so any modifications on
the state builder will be reflected in this object.public ParallelState.Builder retrier(Retrier.Builder retrierBuilder)
Retrier
to this states retries. If a single branch fails then the entire parallel state is
considered failed and eligible for retry.retrierBuilder
- Instance of Retrier.Builder
. Note
that the Retrier
object is not built until the ParallelState
is built so any modifications on
the
state builder will be reflected in this object.public ParallelState.Builder catchers(Catcher.Builder... catcherBuilders)
Catcher
s to this states catchers. If a single branch fails then the entire parallel state
is considered failed and eligible to be caught.catcherBuilders
- Instances of Catcher.Builder
. Note
that the Catcher
object is not built until the ParallelState
is built so any modifications on
the state builder will be reflected in this object.public ParallelState.Builder catcher(Catcher.Builder catcherBuilder)
Catcher
to this states catchers. If a single branch fails then the entire parallel state
is
considered failed and eligible to be caught.catcherBuilder
- Instance of Catcher.Builder
. Note
that the Catcher
object is not built until the ParallelState
is built so any modifications on
the
state builder will be reflected in this object.public ParallelState build()
build
in interface Buildable<State>
ParallelState
object.