software.amazon.awscdk.services.kinesisanalytics

Class CfnApplicationV2

java.lang.Object

software.constructs.Construct

software.amazon.awscdk.core.Construct

software.amazon.awscdk.core.CfnElement

software.amazon.awscdk.core.CfnRefElement

software.amazon.awscdk.core.CfnResource

software.amazon.awscdk.services.kinesisanalytics.CfnApplicationV2

All Implemented Interfaces:

IConstruct, IDependable, IInspectable

@Generated(value="jsii-pacmak/1.74.0 (build 6d08790)",
           date="2023-03-22T19:35:37.333Z")
public class CfnApplicationV2
extends CfnResource
implements IInspectable

A CloudFormation `AWS::KinesisAnalyticsV2::Application`.

Creates an Amazon Kinesis Data Analytics application. For information about creating a Kinesis Data Analytics application, see Creating an 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.*;
 CfnApplicationV2 cfnApplicationV2 = CfnApplicationV2.Builder.create(this, "MyCfnApplicationV2")
         .runtimeEnvironment("runtimeEnvironment")
         .serviceExecutionRole("serviceExecutionRole")
         // the properties below are optional
         .applicationConfiguration(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())
         .applicationDescription("applicationDescription")
         .applicationMaintenanceConfiguration(ApplicationMaintenanceConfigurationProperty.builder()
                 .applicationMaintenanceWindowStartTime("applicationMaintenanceWindowStartTime")
                 .build())
         .applicationMode("applicationMode")
         .applicationName("applicationName")
         .runConfiguration(RunConfigurationProperty.builder()
                 .applicationRestoreConfiguration(ApplicationRestoreConfigurationProperty.builder()
                         .applicationRestoreType("applicationRestoreType")
                         // the properties below are optional
                         .snapshotName("snapshotName")
                         .build())
                 .flinkRunConfiguration(FlinkRunConfigurationProperty.builder()
                         .allowNonRestoredState(false)
                         .build())
                 .build())
         .tags(List.of(CfnTag.builder()
                 .key("key")
                 .value("value")
                 .build()))
         .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CfnApplicationV2.ApplicationCodeConfigurationProperty Describes code configuration for an application.
static interface	CfnApplicationV2.ApplicationConfigurationProperty Specifies the creation parameters for a Kinesis Data Analytics application.
static interface	CfnApplicationV2.ApplicationMaintenanceConfigurationProperty Specifies the maintence window parameters for a Kinesis Data Analytics application.
static interface	CfnApplicationV2.ApplicationRestoreConfigurationProperty Specifies the method and snapshot to use when restarting an application using previously saved application state.
static interface	CfnApplicationV2.ApplicationSnapshotConfigurationProperty Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
static class	CfnApplicationV2.Builder A fluent builder for CfnApplicationV2.
static interface	CfnApplicationV2.CatalogConfigurationProperty The configuration parameters for the default Amazon Glue database.
static interface	CfnApplicationV2.CheckpointConfigurationProperty Describes an application's checkpointing configuration.
static interface	CfnApplicationV2.CodeContentProperty Specifies either the application code, or the location of the application code, for a Flink-based Kinesis Data Analytics application.
static interface	CfnApplicationV2.CSVMappingParametersProperty For a SQL-based Kinesis Data Analytics application, provides additional mapping information when the record format uses delimiters, such as CSV.
static interface	CfnApplicationV2.CustomArtifactConfigurationProperty The configuration of connectors and user-defined functions.
static interface	CfnApplicationV2.DeployAsApplicationConfigurationProperty The information required to deploy a Kinesis Data Analytics Studio notebook as an application with durable state.
static interface	CfnApplicationV2.EnvironmentPropertiesProperty Describes execution properties for a Flink-based Kinesis Data Analytics application.
static interface	CfnApplicationV2.FlinkApplicationConfigurationProperty Describes configuration parameters for a Flink-based Kinesis Data Analytics application or a Studio notebook.
static interface	CfnApplicationV2.FlinkRunConfigurationProperty Describes the starting parameters for a Flink-based Kinesis Data Analytics application.
static interface	CfnApplicationV2.GlueDataCatalogConfigurationProperty The configuration of the Glue Data Catalog that you use for Apache Flink SQL queries and table API transforms that you write in an application.
static interface	CfnApplicationV2.InputLambdaProcessorProperty An object that contains the Amazon Resource Name (ARN) of the Amazon Lambda function that is used to preprocess records in the stream in a SQL-based Kinesis Data Analytics application.
static interface	CfnApplicationV2.InputParallelismProperty For a SQL-based Kinesis Data Analytics application, describes the number of in-application streams to create for a given streaming source.
static interface	CfnApplicationV2.InputProcessingConfigurationProperty For an SQL-based Amazon Kinesis Data Analytics application, describes a processor that is used to preprocess the records in the stream before being processed by your application code.
static interface	CfnApplicationV2.InputProperty When you configure the application input for a SQL-based Kinesis Data Analytics application, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.
static interface	CfnApplicationV2.InputSchemaProperty For a SQL-based Kinesis Data Analytics application, describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
static interface	CfnApplicationV2.JSONMappingParametersProperty For a SQL-based Kinesis Data Analytics application, provides additional mapping information when JSON is the record format on the streaming source.
static interface	CfnApplicationV2.KinesisFirehoseInputProperty For a SQL-based Kinesis Data Analytics application, identifies a Kinesis Data Firehose delivery stream as the streaming source.
static interface	CfnApplicationV2.KinesisStreamsInputProperty Identifies a Kinesis data stream as the streaming source.
static interface	CfnApplicationV2.MappingParametersProperty When you configure a SQL-based Kinesis Data Analytics application's input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
static interface	CfnApplicationV2.MavenReferenceProperty The information required to specify a Maven reference.
static interface	CfnApplicationV2.MonitoringConfigurationProperty Describes configuration parameters for Amazon CloudWatch logging for a Java-based Kinesis Data Analytics application.
static interface	CfnApplicationV2.ParallelismConfigurationProperty Describes parameters for how a Flink-based Kinesis Data Analytics application executes multiple tasks simultaneously.
static interface	CfnApplicationV2.PropertyGroupProperty Property key-value pairs passed into an application.
static interface	CfnApplicationV2.RecordColumnProperty For a SQL-based Kinesis Data Analytics application, describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
static interface	CfnApplicationV2.RecordFormatProperty For a SQL-based Kinesis Data Analytics application, describes the record format and relevant mapping information that should be applied to schematize the records on the stream.
static interface	CfnApplicationV2.RunConfigurationProperty Describes the starting parameters for an Kinesis Data Analytics application.
static interface	CfnApplicationV2.S3ContentBaseLocationProperty The base location of the Amazon Data Analytics application.
static interface	CfnApplicationV2.S3ContentLocationProperty The location of an application or a custom artifact.
static interface	CfnApplicationV2.SqlApplicationConfigurationProperty Describes the inputs, outputs, and reference data sources for a SQL-based Kinesis Data Analytics application.
static interface	CfnApplicationV2.VpcConfigurationProperty Describes the parameters of a VPC used by the application.
static interface	CfnApplicationV2.ZeppelinApplicationConfigurationProperty The configuration of a Kinesis Data Analytics Studio notebook.
static interface	CfnApplicationV2.ZeppelinMonitoringConfigurationProperty Describes configuration parameters for Amazon CloudWatch logging for a Kinesis Data Analytics Studio notebook.

Nested classes/interfaces inherited from interface software.amazon.awscdk.core.IInspectable

IInspectable.Jsii$Default, IInspectable.Jsii$Proxy

Nested classes/interfaces inherited from interface software.amazon.awscdk.core.IConstruct

IConstruct.Jsii$Default

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CFN_RESOURCE_TYPE_NAME The CloudFormation resource type name for this resource class.

Constructor Summary

Constructors

Modifier	Constructor and Description
	CfnApplicationV2(Construct scope, java.lang.String id, CfnApplicationV2Props props) Create a new `AWS::KinesisAnalyticsV2::Application`.
protected	CfnApplicationV2(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
protected	CfnApplicationV2(software.amazon.jsii.JsiiObjectRef objRef)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	getApplicationConfiguration() Use this parameter to configure the application.
java.lang.String	getApplicationDescription() The description of the application.
java.lang.Object	getApplicationMaintenanceConfiguration() `AWS::KinesisAnalyticsV2::Application.ApplicationMaintenanceConfiguration`.
java.lang.String	getApplicationMode() To create a Kinesis Data Analytics Studio notebook, you must set the mode to `INTERACTIVE` .
java.lang.String	getApplicationName() The name of the application.
protected java.util.Map<java.lang.String,java.lang.Object>	getCfnProperties()
java.lang.Object	getRunConfiguration() `AWS::KinesisAnalyticsV2::Application.RunConfiguration`.
java.lang.String	getRuntimeEnvironment() The runtime environment for the application.
java.lang.String	getServiceExecutionRole() Specifies the IAM role that the application uses to access external resources.
TagManager	getTags() A list of one or more tags to assign to the application.
void	inspect(TreeInspector inspector) Examines the CloudFormation resource and discloses attributes.
protected java.util.Map<java.lang.String,java.lang.Object>	renderProperties(java.util.Map<java.lang.String,java.lang.Object> props)
void	setApplicationConfiguration(CfnApplicationV2.ApplicationConfigurationProperty value) Use this parameter to configure the application.
void	setApplicationConfiguration(IResolvable value) Use this parameter to configure the application.
void	setApplicationDescription(java.lang.String value) The description of the application.
void	setApplicationMaintenanceConfiguration(CfnApplicationV2.ApplicationMaintenanceConfigurationProperty value) `AWS::KinesisAnalyticsV2::Application.ApplicationMaintenanceConfiguration`.
void	setApplicationMaintenanceConfiguration(IResolvable value) `AWS::KinesisAnalyticsV2::Application.ApplicationMaintenanceConfiguration`.
void	setApplicationMode(java.lang.String value) To create a Kinesis Data Analytics Studio notebook, you must set the mode to `INTERACTIVE` .
void	setApplicationName(java.lang.String value) The name of the application.
void	setRunConfiguration(CfnApplicationV2.RunConfigurationProperty value) `AWS::KinesisAnalyticsV2::Application.RunConfiguration`.
void	setRunConfiguration(IResolvable value) `AWS::KinesisAnalyticsV2::Application.RunConfiguration`.
void	setRuntimeEnvironment(java.lang.String value) The runtime environment for the application.
void	setServiceExecutionRole(java.lang.String value) Specifies the IAM role that the application uses to access external resources.

Methods inherited from class software.amazon.awscdk.core.CfnResource

addDeletionOverride, addDependsOn, addMetadata, addOverride, addPropertyDeletionOverride, addPropertyOverride, applyRemovalPolicy, applyRemovalPolicy, applyRemovalPolicy, getAtt, getCfnOptions, getCfnResourceType, getMetadata, getUpdatedProperites, isCfnResource, shouldSynthesize, toString, validateProperties

Methods inherited from class software.amazon.awscdk.core.CfnRefElement

getRef

Methods inherited from class software.amazon.awscdk.core.CfnElement

getCreationStack, getLogicalId, getStack, isCfnElement, overrideLogicalId

Methods inherited from class software.amazon.awscdk.core.Construct

getNode, isConstruct, onPrepare, onSynthesize, onValidate, prepare, synthesize, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

CFN_RESOURCE_TYPE_NAME

public static final java.lang.String CFN_RESOURCE_TYPE_NAME

The CloudFormation resource type name for this resource class.

Constructor Detail

CfnApplicationV2

protected CfnApplicationV2(software.amazon.jsii.JsiiObjectRef objRef)

CfnApplicationV2

protected CfnApplicationV2(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

CfnApplicationV2

public CfnApplicationV2(Construct scope,
                        java.lang.String id,
                        CfnApplicationV2Props props)

Create a new `AWS::KinesisAnalyticsV2::Application`.

Parameters:

scope - - scope in which this resource is defined. This parameter is required.

id - - scoped id of the resource. This parameter is required.

props - - resource properties. This parameter is required.

Method Detail

inspect

public void inspect(TreeInspector inspector)

Examines the CloudFormation resource and discloses attributes.

Specified by:

inspect in interface IInspectable

Parameters:

inspector - - tree inspector to collect and process attributes. This parameter is required.

renderProperties

protected java.util.Map<java.lang.String,java.lang.Object> renderProperties(java.util.Map<java.lang.String,java.lang.Object> props)

Overrides:

renderProperties in class CfnResource

Parameters:

props - This parameter is required.

getCfnProperties

protected java.util.Map<java.lang.String,java.lang.Object> getCfnProperties()

Overrides:

getCfnProperties in class CfnResource

getTags

public TagManager getTags()

A list of one or more tags to assign to the application.

A tag is a key-value pair that identifies an application. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50.

getRuntimeEnvironment

public java.lang.String getRuntimeEnvironment()

The runtime environment for the application.

setRuntimeEnvironment

public void setRuntimeEnvironment(java.lang.String value)

The runtime environment for the application.

getServiceExecutionRole

public java.lang.String getServiceExecutionRole()

Specifies the IAM role that the application uses to access external resources.

setServiceExecutionRole

public void setServiceExecutionRole(java.lang.String value)

Specifies the IAM role that the application uses to access external resources.

getApplicationConfiguration

public java.lang.Object getApplicationConfiguration()

Use this parameter to configure the application.

setApplicationConfiguration

public void setApplicationConfiguration(IResolvable value)

Use this parameter to configure the application.

setApplicationConfiguration

public void setApplicationConfiguration(CfnApplicationV2.ApplicationConfigurationProperty value)

Use this parameter to configure the application.

getApplicationDescription

public java.lang.String getApplicationDescription()

The description of the application.

setApplicationDescription

public void setApplicationDescription(java.lang.String value)

The description of the application.

getApplicationMaintenanceConfiguration

public java.lang.Object getApplicationMaintenanceConfiguration()

`AWS::KinesisAnalyticsV2::Application.ApplicationMaintenanceConfiguration`.

setApplicationMaintenanceConfiguration

public void setApplicationMaintenanceConfiguration(IResolvable value)

`AWS::KinesisAnalyticsV2::Application.ApplicationMaintenanceConfiguration`.

setApplicationMaintenanceConfiguration

public void setApplicationMaintenanceConfiguration(CfnApplicationV2.ApplicationMaintenanceConfigurationProperty value)

`AWS::KinesisAnalyticsV2::Application.ApplicationMaintenanceConfiguration`.

getApplicationMode

public java.lang.String getApplicationMode()

To create a Kinesis Data Analytics Studio notebook, you must set the mode to `INTERACTIVE` .

However, for a Kinesis Data Analytics for Apache Flink application, the mode is optional.

setApplicationMode

public void setApplicationMode(java.lang.String value)

To create a Kinesis Data Analytics Studio notebook, you must set the mode to `INTERACTIVE` .

However, for a Kinesis Data Analytics for Apache Flink application, the mode is optional.

getApplicationName

public java.lang.String getApplicationName()

The name of the application.

setApplicationName

public void setApplicationName(java.lang.String value)

The name of the application.

getRunConfiguration

public java.lang.Object getRunConfiguration()

`AWS::KinesisAnalyticsV2::Application.RunConfiguration`.

setRunConfiguration

public void setRunConfiguration(IResolvable value)

`AWS::KinesisAnalyticsV2::Application.RunConfiguration`.

setRunConfiguration

public void setRunConfiguration(CfnApplicationV2.RunConfigurationProperty value)

`AWS::KinesisAnalyticsV2::Application.RunConfiguration`.