Class DistributedMap.Builder
- All Implemented Interfaces:
software.amazon.jsii.Builder<DistributedMap>
- Enclosing class:
DistributedMap
DistributedMap
.-
Method Summary
Modifier and TypeMethodDescriptionbuild()
An optional description for this state.static DistributedMap.Builder
JSONPath expression to select part of the state to be the input to this state.itemBatcher
(ItemBatcher itemBatcher) Specifies to process a group of items in a single child workflow execution.itemReader
(IItemReader itemReader) ItemReader.itemSelector
(Map<String, ? extends Object> itemSelector) The JSON that you want to override your default iteration input (mutually exclusive withparameters
).JSONPath expression to select the array to iterate over.Label.mapExecutionType
(StateMachineType mapExecutionType) MapExecutionType.maxConcurrency
(Number maxConcurrency) MaxConcurrency.maxConcurrencyPath
(String maxConcurrencyPath) MaxConcurrencyPath.outputPath
(String outputPath) JSONPath expression to select part of the state to be the output to this state.resultPath
(String resultPath) JSONPath expression to indicate where to inject the state's output.resultSelector
(Map<String, ? extends Object> resultSelector) The JSON that will replace the state's raw result and become the effective result before ResultPath is applied.resultWriter
(ResultWriter resultWriter) Configuration for S3 location in which to save Map Run results.Optional name for this state.toleratedFailureCount
(Number toleratedFailureCount) ToleratedFailureCount.toleratedFailureCountPath
(String toleratedFailureCountPath) ToleratedFailureCountPath.toleratedFailurePercentage
(Number toleratedFailurePercentage) ToleratedFailurePercentage.toleratedFailurePercentagePath
(String toleratedFailurePercentagePath) ToleratedFailurePercentagePath.
-
Method Details
-
create
@Stability(Stable) public static DistributedMap.Builder create(software.constructs.Construct scope, String id) - Parameters:
scope
- This parameter is required.id
- Descriptive identifier for this chainable. This parameter is required.- Returns:
- a new instance of
DistributedMap.Builder
.
-
comment
An optional description for this state.Default: No comment
- Parameters:
comment
- An optional description for this state. This parameter is required.- Returns:
this
-
inputPath
JSONPath expression to select part of the state to be the input to this state.May also be the special value JsonPath.DISCARD, which will cause the effective input to be the empty object {}.
Default: $
- Parameters:
inputPath
- JSONPath expression to select part of the state to be the input to this state. This parameter is required.- Returns:
this
-
itemSelector
@Stability(Stable) public DistributedMap.Builder itemSelector(Map<String, ? extends Object> itemSelector) The JSON that you want to override your default iteration input (mutually exclusive withparameters
).Default: $
- Parameters:
itemSelector
- The JSON that you want to override your default iteration input (mutually exclusive withparameters
). This parameter is required.- Returns:
this
- See Also:
-
itemsPath
JSONPath expression to select the array to iterate over.Default: $
- Parameters:
itemsPath
- JSONPath expression to select the array to iterate over. This parameter is required.- Returns:
this
-
maxConcurrency
MaxConcurrency.An upper bound on the number of iterations you want running at once.
Default: - full concurrency
- Parameters:
maxConcurrency
- MaxConcurrency. This parameter is required.- Returns:
this
- See Also:
-
maxConcurrencyPath
MaxConcurrencyPath.A JsonPath that specifies the maximum concurrency dynamically from the state input.
Default: - full concurrency
- Parameters:
maxConcurrencyPath
- MaxConcurrencyPath. This parameter is required.- Returns:
this
- See Also:
-
outputPath
JSONPath expression to select part of the state to be the output to this state.May also be the special value JsonPath.DISCARD, which will cause the effective output to be the empty object {}.
Default: $
- Parameters:
outputPath
- JSONPath expression to select part of the state to be the output to this state. This parameter is required.- Returns:
this
-
resultPath
JSONPath expression to indicate where to inject the state's output.May also be the special value JsonPath.DISCARD, which will cause the state's input to become its output.
Default: $
- Parameters:
resultPath
- JSONPath expression to indicate where to inject the state's output. This parameter is required.- Returns:
this
-
resultSelector
@Stability(Stable) public DistributedMap.Builder resultSelector(Map<String, ? extends Object> resultSelector) The JSON that will replace the state's raw result and become the effective result before ResultPath is applied.You can use ResultSelector to create a payload with values that are static or selected from the state's raw result.
Default: - None
- Parameters:
resultSelector
- The JSON that will replace the state's raw result and become the effective result before ResultPath is applied. This parameter is required.- Returns:
this
- See Also:
-
stateName
Optional name for this state.Default: - The construct ID will be used as state name
- Parameters:
stateName
- Optional name for this state. This parameter is required.- Returns:
this
-
itemBatcher
Specifies to process a group of items in a single child workflow execution.Default: - No itemBatcher
- Parameters:
itemBatcher
- Specifies to process a group of items in a single child workflow execution. This parameter is required.- Returns:
this
-
itemReader
ItemReader.Configuration for where to read items dataset in S3 to iterate
Default: - No itemReader
- Parameters:
itemReader
- ItemReader. This parameter is required.- Returns:
this
-
label
Label.Unique name for the Distributed Map state added to each Map Run
Default: - No label
- Parameters:
label
- Label. This parameter is required.- Returns:
this
-
mapExecutionType
@Stability(Stable) public DistributedMap.Builder mapExecutionType(StateMachineType mapExecutionType) MapExecutionType.The execution type of the distributed map state
This property overwrites ProcessorConfig.executionType
Default: StateMachineType.STANDARD
- Parameters:
mapExecutionType
- MapExecutionType. This parameter is required.- Returns:
this
-
resultWriter
Configuration for S3 location in which to save Map Run results.Default: - No resultWriter
- Parameters:
resultWriter
- Configuration for S3 location in which to save Map Run results. This parameter is required.- Returns:
this
-
toleratedFailureCount
@Stability(Stable) public DistributedMap.Builder toleratedFailureCount(Number toleratedFailureCount) ToleratedFailureCount.Number of failed items to tolerate in a Map Run, as static number
Default: - No toleratedFailureCount
- Parameters:
toleratedFailureCount
- ToleratedFailureCount. This parameter is required.- Returns:
this
-
toleratedFailureCountPath
@Stability(Stable) public DistributedMap.Builder toleratedFailureCountPath(String toleratedFailureCountPath) ToleratedFailureCountPath.Number of failed items to tolerate in a Map Run, as JsonPath
Default: - No toleratedFailureCountPath
- Parameters:
toleratedFailureCountPath
- ToleratedFailureCountPath. This parameter is required.- Returns:
this
-
toleratedFailurePercentage
@Stability(Stable) public DistributedMap.Builder toleratedFailurePercentage(Number toleratedFailurePercentage) ToleratedFailurePercentage.Percentage of failed items to tolerate in a Map Run, as static number
Default: - No toleratedFailurePercentage
- Parameters:
toleratedFailurePercentage
- ToleratedFailurePercentage. This parameter is required.- Returns:
this
-
toleratedFailurePercentagePath
@Stability(Stable) public DistributedMap.Builder toleratedFailurePercentagePath(String toleratedFailurePercentagePath) ToleratedFailurePercentagePath.Percentage of failed items to tolerate in a Map Run, as JsonPath
Default: - No toleratedFailurePercentagePath
- Parameters:
toleratedFailurePercentagePath
- ToleratedFailurePercentagePath. This parameter is required.- Returns:
this
-
build
- Specified by:
build
in interfacesoftware.amazon.jsii.Builder<DistributedMap>
- Returns:
- a newly built instance of
DistributedMap
.
-