Package software.amazon.awscdk.services.stepfunctions

Interface DistributedMapProps

All Superinterfaces:
AssignableStateOptions, software.amazon.jsii.JsiiSerializable, JsonataCommonOptions, JsonPathCommonOptions, MapBaseJsonataOptions, MapBaseJsonPathOptions, MapBaseOptions, MapBaseProps, StateBaseProps
All Known Implementing Classes:
DistributedMapProps.Jsii$Proxy
@Generated(value="jsii-pacmak/1.116.0 (build 0eddcff)", date="2025-10-24T13:34:47.827Z") @Stability(Stable) public interface DistributedMapProps extends software.amazon.jsii.JsiiSerializable, MapBaseProps, MapBaseOptions, MapBaseJsonPathOptions, MapBaseJsonataOptions
Properties for configuring a Distribute Map state.

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"));

  • Method Details

    • getItemBatcher

      @Stability(Stable) @Nullable default ItemBatcher getItemBatcher()
      Specifies to process a group of items in a single child workflow execution.

      Default: - No itemBatcher

    • getItemReader

      @Stability(Stable) @Nullable default IItemReader getItemReader()
      ItemReader.

      Configuration for where to read items dataset in S3 to iterate

      Default: - No itemReader

    • getLabel

      @Stability(Stable) @Nullable default String getLabel()
      Label.

      Unique name for the Distributed Map state added to each Map Run

      Default: - No label

    • getMapExecutionType

      @Stability(Stable) @Nullable default StateMachineType getMapExecutionType()
      MapExecutionType.

      The execution type of the distributed map state

      This property overwrites ProcessorConfig.executionType

      Default: StateMachineType.STANDARD

    • getResultWriter

      @Stability(Deprecated) @Deprecated @Nullable default ResultWriter getResultWriter()
      Deprecated.
      Use
      invalid reference 
      resultWriterV2
      (deprecated) Configuration for S3 location in which to save Map Run results.

      Default: - No resultWriter

    • getResultWriterV2

      @Stability(Stable) @Nullable default ResultWriterV2 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

      @Stability(Stable) @Nullable default Number getToleratedFailureCount()
      ToleratedFailureCount.

      Number of failed items to tolerate in a Map Run, as static number

      Default: - No toleratedFailureCount

    • getToleratedFailureCountPath

      @Stability(Stable) @Nullable default String getToleratedFailureCountPath()
      ToleratedFailureCountPath.

      Number of failed items to tolerate in a Map Run, as JsonPath

      Default: - No toleratedFailureCountPath

    • getToleratedFailurePercentage

      @Stability(Stable) @Nullable default Number getToleratedFailurePercentage()
      ToleratedFailurePercentage.

      Percentage of failed items to tolerate in a Map Run, as static number

      Default: - No toleratedFailurePercentage

    • getToleratedFailurePercentagePath

      @Stability(Stable) @Nullable default String getToleratedFailurePercentagePath()
      ToleratedFailurePercentagePath.

      Percentage of failed items to tolerate in a Map Run, as JsonPath

      Default: - No toleratedFailurePercentagePath

    • getItemSelector

      @Stability(Stable) @Nullable default Map<String,Object> getItemSelector()
      The JSON that you want to override your default iteration input (mutually exclusive with parameters and jsonataItemSelector).

      Default: $

      Specified by:
      getItemSelector in interface MapBaseOptions
      See Also:

    • getJsonataItemSelector

      @Stability(Stable) @Nullable default String getJsonataItemSelector()
      Jsonata expression that evaluates to a JSON array to override your default iteration input (mutually exclusive with parameters and itemSelector).

      Example value: {% {\"foo\": \"foo\", \"input\": $states.input} %}

      Default: $

      Specified by:
      getJsonataItemSelector in interface MapBaseOptions

    • getMaxConcurrency

      @Stability(Stable) @Nullable default Number getMaxConcurrency()
      MaxConcurrency.

      An upper bound on the number of iterations you want running at once.

      Default: - full concurrency

      Specified by:
      getMaxConcurrency in interface MapBaseOptions
      See Also:

    • getAssign

      @Stability(Stable) @Nullable default Map<String,Object> getAssign()
      Workflow variables to store in this step.

      Using workflow variables, you can store data in a step and retrieve that data in future steps.

      Default: - Not assign variables

      Specified by:
      getAssign in interface AssignableStateOptions
      See Also:

    • getItemsPath

      @Stability(Stable) @Nullable default String getItemsPath()
      JSONPath expression to select the array to iterate over.

      Default: $

      Specified by:
      getItemsPath in interface MapBaseJsonPathOptions

    • getMaxConcurrencyPath

      @Stability(Stable) @Nullable default String getMaxConcurrencyPath()
      MaxConcurrencyPath.

      A JsonPath that specifies the maximum concurrency dynamically from the state input.

      Default: - full concurrency

      Specified by:
      getMaxConcurrencyPath in interface MapBaseJsonPathOptions
      See Also:

    • getResultPath

      @Stability(Stable) @Nullable default String getResultPath()
      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: $

      Specified by:
      getResultPath in interface MapBaseJsonPathOptions

    • getResultSelector

      @Stability(Stable) @Nullable default Map<String,Object> getResultSelector()
      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

      Specified by:
      getResultSelector in interface MapBaseJsonPathOptions
      See Also:

    • getInputPath

      @Stability(Stable) @Nullable default String getInputPath()
      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: $

      Specified by:
      getInputPath in interface JsonPathCommonOptions

    • getOutputPath

      @Stability(Stable) @Nullable default String getOutputPath()
      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: $

      Specified by:
      getOutputPath in interface JsonPathCommonOptions

    • getItems

      @Stability(Stable) @Nullable default ProvideItems getItems()
      The array that the Map state will iterate over.

      Default: - The state input as is.

      Specified by:
      getItems in interface MapBaseJsonataOptions

    • getOutputs

      @Stability(Stable) @Nullable default Object getOutputs()
      Used to specify and transform output from the state.

      When specified, the value overrides the state output default. The output field accepts any JSON value (object, array, string, number, boolean, null). Any string value, including those inside objects or arrays, will be evaluated as JSONata if surrounded by {% %} characters. Output also accepts a JSONata expression directly.

      Default: - $states.result or $states.errorOutput

      Specified by:
      getOutputs in interface JsonataCommonOptions
      See Also:

    • builder

      @Stability(Stable) static DistributedMapProps.Builder builder()
      Returns:
      a DistributedMapProps.Builder of DistributedMapProps