Interface DistributedMapProps
- All Superinterfaces:
AssignableStateOptions,software.amazon.jsii.JsiiSerializable,JsonataCommonOptions,JsonPathCommonOptions,MapBaseJsonataOptions,MapBaseJsonPathOptions,MapBaseOptions,MapBaseProps,StateBaseProps
- All Known Implementing Classes:
DistributedMapProps.Jsii$Proxy
Example:
/**
* JSON state input:
* {
* "bucketName": "my-bucket",
* "prefix": "item"
* }
*/
DistributedMap distributedMap = DistributedMap.Builder.create(this, "DistributedMap")
.itemReader(S3ObjectsItemReader.Builder.create()
.bucketNamePath(JsonPath.stringAt("$.bucketName"))
.prefix(JsonPath.stringAt("$.prefix"))
.build())
.build();
distributedMap.itemProcessor(new Pass(this, "Pass"));
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic final classA builder forDistributedMapPropsstatic final classAn implementation forDistributedMapProps -
Method Summary
Modifier and TypeMethodDescriptionstatic DistributedMapProps.Builderbuilder()default ItemBatcherSpecifies to process a group of items in a single child workflow execution.default IItemReaderItemReader.default StringgetLabel()Label.default StateMachineTypeMapExecutionType.default ResultWriterDeprecated.default ResultWriterV2Configuration for S3 location in which to save Map Run results Enable "@aws-cdk/aws-stepfunctions:useDistributedMapResultWriterV2" feature in the context to use resultWriterV2 Example: stack.node.setContext("@aws-cdk/aws-stepfunctions:useDistributedMapResultWriterV2", true);default NumberToleratedFailureCount.default StringToleratedFailureCountPath.default NumberToleratedFailurePercentage.default StringToleratedFailurePercentagePath.Methods inherited from interface software.amazon.awscdk.services.stepfunctions.AssignableStateOptions
getAssignMethods inherited from interface software.amazon.jsii.JsiiSerializable
$jsii$toJsonMethods inherited from interface software.amazon.awscdk.services.stepfunctions.JsonataCommonOptions
getOutputsMethods inherited from interface software.amazon.awscdk.services.stepfunctions.JsonPathCommonOptions
getInputPath, getOutputPathMethods inherited from interface software.amazon.awscdk.services.stepfunctions.MapBaseJsonataOptions
getItemsMethods inherited from interface software.amazon.awscdk.services.stepfunctions.MapBaseJsonPathOptions
getItemsPath, getMaxConcurrencyPath, getResultPath, getResultSelectorMethods inherited from interface software.amazon.awscdk.services.stepfunctions.MapBaseOptions
getItemSelector, getJsonataItemSelector, getJsonataMaxConcurrency, getMaxConcurrencyMethods inherited from interface software.amazon.awscdk.services.stepfunctions.StateBaseProps
getComment, getQueryLanguage, getStateName
-
Method Details
-
getItemBatcher
Specifies to process a group of items in a single child workflow execution.Default: - No itemBatcher
-
getItemReader
ItemReader.Configuration for where to read items dataset in S3 to iterate
Default: - No itemReader
-
getLabel
Label.Unique name for the Distributed Map state added to each Map Run
Default: - No label
-
getMapExecutionType
MapExecutionType.The execution type of the distributed map state
This property overwrites ProcessorConfig.executionType
Default: StateMachineType.STANDARD
-
getResultWriter
Deprecated.Useinvalid reference
resultWriterV2(deprecated) Configuration for S3 location in which to save Map Run results.Default: - No resultWriter
-
getResultWriterV2
Configuration for S3 location in which to save Map Run results Enable "@aws-cdk/aws-stepfunctions:useDistributedMapResultWriterV2" feature in the context to use resultWriterV2 Example: stack.node.setContext("@aws-cdk/aws-stepfunctions:useDistributedMapResultWriterV2", true);Default: - No resultWriterV2
-
getToleratedFailureCount
ToleratedFailureCount.Number of failed items to tolerate in a Map Run, as static number
Default: - No toleratedFailureCount
-
getToleratedFailureCountPath
ToleratedFailureCountPath.Number of failed items to tolerate in a Map Run, as JsonPath
Default: - No toleratedFailureCountPath
-
getToleratedFailurePercentage
ToleratedFailurePercentage.Percentage of failed items to tolerate in a Map Run, as static number
Default: - No toleratedFailurePercentage
-
getToleratedFailurePercentagePath
ToleratedFailurePercentagePath.Percentage of failed items to tolerate in a Map Run, as JsonPath
Default: - No toleratedFailurePercentagePath
-
builder
- Returns:
- a
DistributedMapProps.BuilderofDistributedMapProps
-
invalid reference