Interface CfnApplicationV2.ApplicationConfigurationProperty
- All Superinterfaces:
software.amazon.jsii.JsiiSerializable
- All Known Implementing Classes:
CfnApplicationV2.ApplicationConfigurationProperty.Jsii$Proxy
- Enclosing class:
CfnApplicationV2
@Stability(Stable)
public static interface CfnApplicationV2.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.kinesisanalytics.*; 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();
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic final class
A builder forCfnApplicationV2.ApplicationConfigurationProperty
static final class
An implementation forCfnApplicationV2.ApplicationConfigurationProperty
-
Method Summary
Modifier and TypeMethodDescriptionbuilder()
default Object
The code location and type parameters for a Flink-based Kinesis Data Analytics application.default Object
Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.default Object
Describes execution properties for a Flink-based Kinesis Data Analytics application.default Object
The creation and update parameters for a Flink-based Kinesis Data Analytics application.default Object
The creation and update parameters for a SQL-based Kinesis Data Analytics application.default Object
The array of descriptions of VPC configurations available to the application.default Object
The configuration parameters for a Kinesis Data Analytics Studio notebook.Methods inherited from interface software.amazon.jsii.JsiiSerializable
$jsii$toJson
-
Method Details
-
getApplicationCodeConfiguration
The code location and type parameters for a Flink-based Kinesis Data Analytics application. -
getApplicationSnapshotConfiguration
Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application. -
getEnvironmentProperties
Describes execution properties for a Flink-based Kinesis Data Analytics application. -
getFlinkApplicationConfiguration
The creation and update parameters for a Flink-based Kinesis Data Analytics application. -
getSqlApplicationConfiguration
The creation and update parameters for a SQL-based Kinesis Data Analytics application. -
getVpcConfigurations
The array of descriptions of VPC configurations available to the application. -
getZeppelinApplicationConfiguration
The configuration parameters for a Kinesis Data Analytics Studio notebook. -
builder
-