Interface CfnApplication.ApplicationConfigurationProperty

All Superinterfaces:
software.amazon.jsii.JsiiSerializable
All Known Implementing Classes:
CfnApplication.ApplicationConfigurationProperty.Jsii$Proxy
Enclosing class:
CfnApplication

@Stability(Stable) public static interface CfnApplication.ApplicationConfigurationProperty extends software.amazon.jsii.JsiiSerializable
Specifies the creation parameters for a Kinesis Data Analytics application.

Example:

 // The code below shows an example of how to instantiate this type.
 // The values are placeholders you should change.
 import software.amazon.awscdk.services.kinesisanalyticsv2.*;
 ApplicationConfigurationProperty applicationConfigurationProperty = ApplicationConfigurationProperty.builder()
         .applicationCodeConfiguration(ApplicationCodeConfigurationProperty.builder()
                 .codeContent(CodeContentProperty.builder()
                         .s3ContentLocation(S3ContentLocationProperty.builder()
                                 .bucketArn("bucketArn")
                                 .fileKey("fileKey")
                                 // the properties below are optional
                                 .objectVersion("objectVersion")
                                 .build())
                         .textContent("textContent")
                         .zipFileContent("zipFileContent")
                         .build())
                 .codeContentType("codeContentType")
                 .build())
         .applicationSnapshotConfiguration(ApplicationSnapshotConfigurationProperty.builder()
                 .snapshotsEnabled(false)
                 .build())
         .environmentProperties(EnvironmentPropertiesProperty.builder()
                 .propertyGroups(List.of(PropertyGroupProperty.builder()
                         .propertyGroupId("propertyGroupId")
                         .propertyMap(Map.of(
                                 "propertyMapKey", "propertyMap"))
                         .build()))
                 .build())
         .flinkApplicationConfiguration(FlinkApplicationConfigurationProperty.builder()
                 .checkpointConfiguration(CheckpointConfigurationProperty.builder()
                         .configurationType("configurationType")
                         // the properties below are optional
                         .checkpointingEnabled(false)
                         .checkpointInterval(123)
                         .minPauseBetweenCheckpoints(123)
                         .build())
                 .monitoringConfiguration(MonitoringConfigurationProperty.builder()
                         .configurationType("configurationType")
                         // the properties below are optional
                         .logLevel("logLevel")
                         .metricsLevel("metricsLevel")
                         .build())
                 .parallelismConfiguration(ParallelismConfigurationProperty.builder()
                         .configurationType("configurationType")
                         // the properties below are optional
                         .autoScalingEnabled(false)
                         .parallelism(123)
                         .parallelismPerKpu(123)
                         .build())
                 .build())
         .sqlApplicationConfiguration(SqlApplicationConfigurationProperty.builder()
                 .inputs(List.of(InputProperty.builder()
                         .inputSchema(InputSchemaProperty.builder()
                                 .recordColumns(List.of(RecordColumnProperty.builder()
                                         .name("name")
                                         .sqlType("sqlType")
                                         // the properties below are optional
                                         .mapping("mapping")
                                         .build()))
                                 .recordFormat(RecordFormatProperty.builder()
                                         .recordFormatType("recordFormatType")
                                         // the properties below are optional
                                         .mappingParameters(MappingParametersProperty.builder()
                                                 .csvMappingParameters(CSVMappingParametersProperty.builder()
                                                         .recordColumnDelimiter("recordColumnDelimiter")
                                                         .recordRowDelimiter("recordRowDelimiter")
                                                         .build())
                                                 .jsonMappingParameters(JSONMappingParametersProperty.builder()
                                                         .recordRowPath("recordRowPath")
                                                         .build())
                                                 .build())
                                         .build())
                                 // the properties below are optional
                                 .recordEncoding("recordEncoding")
                                 .build())
                         .namePrefix("namePrefix")
                         // the properties below are optional
                         .inputParallelism(InputParallelismProperty.builder()
                                 .count(123)
                                 .build())
                         .inputProcessingConfiguration(InputProcessingConfigurationProperty.builder()
                                 .inputLambdaProcessor(InputLambdaProcessorProperty.builder()
                                         .resourceArn("resourceArn")
                                         .build())
                                 .build())
                         .kinesisFirehoseInput(KinesisFirehoseInputProperty.builder()
                                 .resourceArn("resourceArn")
                                 .build())
                         .kinesisStreamsInput(KinesisStreamsInputProperty.builder()
                                 .resourceArn("resourceArn")
                                 .build())
                         .build()))
                 .build())
         .vpcConfigurations(List.of(VpcConfigurationProperty.builder()
                 .securityGroupIds(List.of("securityGroupIds"))
                 .subnetIds(List.of("subnetIds"))
                 .build()))
         .zeppelinApplicationConfiguration(ZeppelinApplicationConfigurationProperty.builder()
                 .catalogConfiguration(CatalogConfigurationProperty.builder()
                         .glueDataCatalogConfiguration(GlueDataCatalogConfigurationProperty.builder()
                                 .databaseArn("databaseArn")
                                 .build())
                         .build())
                 .customArtifactsConfiguration(List.of(CustomArtifactConfigurationProperty.builder()
                         .artifactType("artifactType")
                         // the properties below are optional
                         .mavenReference(MavenReferenceProperty.builder()
                                 .artifactId("artifactId")
                                 .groupId("groupId")
                                 .version("version")
                                 .build())
                         .s3ContentLocation(S3ContentLocationProperty.builder()
                                 .bucketArn("bucketArn")
                                 .fileKey("fileKey")
                                 // the properties below are optional
                                 .objectVersion("objectVersion")
                                 .build())
                         .build()))
                 .deployAsApplicationConfiguration(DeployAsApplicationConfigurationProperty.builder()
                         .s3ContentLocation(S3ContentBaseLocationProperty.builder()
                                 .bucketArn("bucketArn")
                                 // the properties below are optional
                                 .basePath("basePath")
                                 .build())
                         .build())
                 .monitoringConfiguration(ZeppelinMonitoringConfigurationProperty.builder()
                         .logLevel("logLevel")
                         .build())
                 .build())
         .build();
 
  • Method Details

    • getApplicationCodeConfiguration

      @Stability(Stable) @Nullable default Object getApplicationCodeConfiguration()
      The code location and type parameters for a Flink-based Kinesis Data Analytics application.
    • getApplicationSnapshotConfiguration

      @Stability(Stable) @Nullable default Object getApplicationSnapshotConfiguration()
      Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    • getEnvironmentProperties

      @Stability(Stable) @Nullable default Object getEnvironmentProperties()
      Describes execution properties for a Flink-based Kinesis Data Analytics application.
    • getFlinkApplicationConfiguration

      @Stability(Stable) @Nullable default Object getFlinkApplicationConfiguration()
      The creation and update parameters for a Flink-based Kinesis Data Analytics application.
    • getSqlApplicationConfiguration

      @Stability(Stable) @Nullable default Object getSqlApplicationConfiguration()
      The creation and update parameters for a SQL-based Kinesis Data Analytics application.
    • getVpcConfigurations

      @Stability(Stable) @Nullable default Object getVpcConfigurations()
      The array of descriptions of VPC configurations available to the application.
    • getZeppelinApplicationConfiguration

      @Stability(Stable) @Nullable default Object getZeppelinApplicationConfiguration()
      The configuration parameters for a Kinesis Data Analytics Studio notebook.
    • builder

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