Package software.amazon.awscdk.services.kinesisanalyticsv2

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

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	CfnApplication.ApplicationConfigurationProperty.Builder	A builder for CfnApplication.ApplicationConfigurationProperty
static final class	CfnApplication.ApplicationConfigurationProperty.Jsii$Proxy	An implementation for CfnApplication.ApplicationConfigurationProperty

Method Summary

Modifier and Type	Method	Description
static CfnApplication.ApplicationConfigurationProperty.Builder	builder()
default Object	getApplicationCodeConfiguration()	The code location and type parameters for a Flink-based Kinesis Data Analytics application.
default Object	getApplicationSnapshotConfiguration()	Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
default Object	getEnvironmentProperties()	Describes execution properties for a Flink-based Kinesis Data Analytics application.
default Object	getFlinkApplicationConfiguration()	The creation and update parameters for a Flink-based Kinesis Data Analytics application.
default Object	getSqlApplicationConfiguration()	The creation and update parameters for a SQL-based Kinesis Data Analytics application.
default Object	getVpcConfigurations()	The array of descriptions of VPC configurations available to the application.
default Object	getZeppelinApplicationConfiguration()	The configuration parameters for a Kinesis Data Analytics Studio notebook.

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

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