ApplicationCodeConfig

class aws_cdk.aws_kinesisanalytics_flink.ApplicationCodeConfig(*, application_code_configuration_property, bucket)

Bases: object

(experimental) The return type of {@link ApplicationCode.bind}. This represents CloudFormation configuration and an s3 bucket holding the Flink application JAR file.

Parameters:

• application_code_configuration_property (Union[ApplicationConfigurationProperty, Dict[str, Any]]) – (experimental) Low-level Cloudformation ApplicationConfigurationProperty.

• bucket (IBucket) – (experimental) S3 Bucket that stores the Flink application code.

Stability:

experimental

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
import aws_cdk.aws_kinesisanalytics_flink as kinesisanalytics_flink
import aws_cdk.aws_s3 as s3

# bucket: s3.Bucket

application_code_config = kinesisanalytics_flink.ApplicationCodeConfig(
    application_code_configuration_property=ApplicationConfigurationProperty(
        application_code_configuration=ApplicationCodeConfigurationProperty(
            code_content=CodeContentProperty(
                s3_content_location=S3ContentLocationProperty(
                    bucket_arn="bucketArn",
                    file_key="fileKey",

                    # the properties below are optional
                    object_version="objectVersion"
                ),
                text_content="textContent",
                zip_file_content="zipFileContent"
            ),
            code_content_type="codeContentType"
        ),
        application_snapshot_configuration=ApplicationSnapshotConfigurationProperty(
            snapshots_enabled=False
        ),
        environment_properties=EnvironmentPropertiesProperty(
            property_groups=[PropertyGroupProperty(
                property_group_id="propertyGroupId",
                property_map={
                    "property_map_key": "propertyMap"
                }
            )]
        ),
        flink_application_configuration=FlinkApplicationConfigurationProperty(
            checkpoint_configuration=CheckpointConfigurationProperty(
                configuration_type="configurationType",

                # the properties below are optional
                checkpointing_enabled=False,
                checkpoint_interval=123,
                min_pause_between_checkpoints=123
            ),
            monitoring_configuration=MonitoringConfigurationProperty(
                configuration_type="configurationType",

                # the properties below are optional
                log_level="logLevel",
                metrics_level="metricsLevel"
            ),
            parallelism_configuration=ParallelismConfigurationProperty(
                configuration_type="configurationType",

                # the properties below are optional
                auto_scaling_enabled=False,
                parallelism=123,
                parallelism_per_kpu=123
            )
        ),
        sql_application_configuration=SqlApplicationConfigurationProperty(
            inputs=[InputProperty(
                input_schema=InputSchemaProperty(
                    record_columns=[RecordColumnProperty(
                        name="name",
                        sql_type="sqlType",

                        # the properties below are optional
                        mapping="mapping"
                    )],
                    record_format=RecordFormatProperty(
                        record_format_type="recordFormatType",

                        # the properties below are optional
                        mapping_parameters=MappingParametersProperty(
                            csv_mapping_parameters=CSVMappingParametersProperty(
                                record_column_delimiter="recordColumnDelimiter",
                                record_row_delimiter="recordRowDelimiter"
                            ),
                            json_mapping_parameters=JSONMappingParametersProperty(
                                record_row_path="recordRowPath"
                            )
                        )
                    ),

                    # the properties below are optional
                    record_encoding="recordEncoding"
                ),
                name_prefix="namePrefix",

                # the properties below are optional
                input_parallelism=InputParallelismProperty(
                    count=123
                ),
                input_processing_configuration=InputProcessingConfigurationProperty(
                    input_lambda_processor=InputLambdaProcessorProperty(
                        resource_arn="resourceArn"
                    )
                ),
                kinesis_firehose_input=KinesisFirehoseInputProperty(
                    resource_arn="resourceArn"
                ),
                kinesis_streams_input=KinesisStreamsInputProperty(
                    resource_arn="resourceArn"
                )
            )]
        ),
        vpc_configurations=[VpcConfigurationProperty(
            security_group_ids=["securityGroupIds"],
            subnet_ids=["subnetIds"]
        )],
        zeppelin_application_configuration=ZeppelinApplicationConfigurationProperty(
            catalog_configuration=CatalogConfigurationProperty(
                glue_data_catalog_configuration=GlueDataCatalogConfigurationProperty(
                    database_arn="databaseArn"
                )
            ),
            custom_artifacts_configuration=[CustomArtifactConfigurationProperty(
                artifact_type="artifactType",

                # the properties below are optional
                maven_reference=MavenReferenceProperty(
                    artifact_id="artifactId",
                    group_id="groupId",
                    version="version"
                ),
                s3_content_location=S3ContentLocationProperty(
                    bucket_arn="bucketArn",
                    file_key="fileKey",

                    # the properties below are optional
                    object_version="objectVersion"
                )
            )],
            deploy_as_application_configuration=DeployAsApplicationConfigurationProperty(
                s3_content_location=S3ContentBaseLocationProperty(
                    bucket_arn="bucketArn",

                    # the properties below are optional
                    base_path="basePath"
                )
            ),
            monitoring_configuration=ZeppelinMonitoringConfigurationProperty(
                log_level="logLevel"
            )
        )
    ),
    bucket=bucket
)

Attributes

application_code_configuration_property

(experimental) Low-level Cloudformation ApplicationConfigurationProperty.

Stability:

experimental

bucket

(experimental) S3 Bucket that stores the Flink application code.

Stability:

experimental