Package software.amazon.awscdk.services.stepfunctions.tasks

Interface EmrContainersStartJobRunJsonataProps

All Superinterfaces:
AssignableStateOptions, software.amazon.jsii.JsiiSerializable, JsonataCommonOptions, StateBaseProps, TaskStateBaseOptions, TaskStateJsonataBaseProps
All Known Implementing Classes:
EmrContainersStartJobRunJsonataProps.Jsii$Proxy
@Generated(value="jsii-pacmak/1.116.0 (build 0eddcff)", date="2025-10-29T11:15:49.756Z") @Stability(Stable) public interface EmrContainersStartJobRunJsonataProps extends software.amazon.jsii.JsiiSerializable, TaskStateJsonataBaseProps
Properties for calling EMR Containers StartJobRun using JSONata.

Example: 

 // The code below shows an example of how to instantiate this type.
 // The values are placeholders you should change.
 import software.amazon.awscdk.*;
 import software.amazon.awscdk.services.iam.*;
 import software.amazon.awscdk.services.logs.*;
 import software.amazon.awscdk.services.s3.*;
 import software.amazon.awscdk.services.stepfunctions.*;
 import software.amazon.awscdk.services.stepfunctions.tasks.*;
 ApplicationConfiguration applicationConfiguration_;
 Object assign;
 Bucket bucket;
 Classification classification;
 LogGroup logGroup;
 Object outputs;
 ReleaseLabel releaseLabel;
 Role role;
 TaskInput taskInput;
 TaskRole taskRole;
 Timeout timeout;
 VirtualClusterInput virtualClusterInput;
 EmrContainersStartJobRunJsonataProps emrContainersStartJobRunJsonataProps = EmrContainersStartJobRunJsonataProps.builder()
         .jobDriver(JobDriver.builder()
                 .sparkSubmitJobDriver(SparkSubmitJobDriver.builder()
                         .entryPoint(taskInput)
                         // the properties below are optional
                         .entryPointArguments(taskInput)
                         .sparkSubmitParameters("sparkSubmitParameters")
                         .build())
                 .build())
         .releaseLabel(releaseLabel)
         .virtualCluster(virtualClusterInput)
         // the properties below are optional
         .applicationConfig(List.of(ApplicationConfiguration.builder()
                 .classification(classification)
                 // the properties below are optional
                 .nestedConfig(List.of(applicationConfiguration_))
                 .properties(Map.of(
                         "propertiesKey", "properties"))
                 .build()))
         .assign(Map.of(
                 "assignKey", assign))
         .comment("comment")
         .credentials(Credentials.builder()
                 .role(taskRole)
                 .build())
         .executionRole(role)
         .heartbeat(Duration.minutes(30))
         .heartbeatTimeout(timeout)
         .integrationPattern(IntegrationPattern.REQUEST_RESPONSE)
         .jobName("jobName")
         .monitoring(Monitoring.builder()
                 .logBucket(bucket)
                 .logging(false)
                 .logGroup(logGroup)
                 .logStreamNamePrefix("logStreamNamePrefix")
                 .persistentAppUI(false)
                 .build())
         .outputs(outputs)
         .queryLanguage(QueryLanguage.JSON_PATH)
         .stateName("stateName")
         .tags(Map.of(
                 "tagsKey", "tags"))
         .taskTimeout(timeout)
         .timeout(Duration.minutes(30))
         .build();