Class CfnApplicationPropsMixin.ApplicationConfigurationProperty
Specifies the creation parameters for a Managed Service for Apache Flink application.
Inherited Members
Namespace: Amazon.CDK.CfnPropertyMixins.AWS.KinesisAnalyticsV2
Assembly: Amazon.CDK.CfnPropertyMixins.dll
Syntax (csharp)
public class CfnApplicationPropsMixin.ApplicationConfigurationProperty : CfnApplicationPropsMixin.IApplicationConfigurationProperty
Syntax (vb)
Public Class CfnApplicationPropsMixin.ApplicationConfigurationProperty Implements CfnApplicationPropsMixin.IApplicationConfigurationProperty
Remarks
ExampleMetadata: fixture=_generated
Examples
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
using Amazon.CDK.CfnPropertyMixins.AWS.KinesisAnalyticsV2;
var applicationConfigurationProperty = new ApplicationConfigurationProperty {
ApplicationCodeConfiguration = new ApplicationCodeConfigurationProperty {
CodeContent = new CodeContentProperty {
S3ContentLocation = new S3ContentLocationProperty {
BucketArn = "bucketArn",
FileKey = "fileKey",
ObjectVersion = "objectVersion"
},
TextContent = "textContent",
ZipFileContent = "zipFileContent"
},
CodeContentType = "codeContentType"
},
ApplicationEncryptionConfiguration = new ApplicationEncryptionConfigurationProperty {
KeyId = "keyId",
KeyType = "keyType"
},
ApplicationSnapshotConfiguration = new ApplicationSnapshotConfigurationProperty {
SnapshotsEnabled = false
},
ApplicationSystemRollbackConfiguration = new ApplicationSystemRollbackConfigurationProperty {
RollbackEnabled = false
},
EnvironmentProperties = new EnvironmentPropertiesProperty {
PropertyGroups = new [] { new PropertyGroupProperty {
PropertyGroupId = "propertyGroupId",
PropertyMap = new Dictionary<string, string> {
{ "propertyMapKey", "propertyMap" }
}
} }
},
FlinkApplicationConfiguration = new FlinkApplicationConfigurationProperty {
CheckpointConfiguration = new CheckpointConfigurationProperty {
CheckpointingEnabled = false,
CheckpointInterval = 123,
ConfigurationType = "configurationType",
MinPauseBetweenCheckpoints = 123
},
MonitoringConfiguration = new MonitoringConfigurationProperty {
ConfigurationType = "configurationType",
LogLevel = "logLevel",
MetricsLevel = "metricsLevel"
},
ParallelismConfiguration = new ParallelismConfigurationProperty {
AutoScalingEnabled = false,
ConfigurationType = "configurationType",
Parallelism = 123,
ParallelismPerKpu = 123
}
},
SqlApplicationConfiguration = new SqlApplicationConfigurationProperty {
Inputs = new [] { new InputProperty {
InputParallelism = new InputParallelismProperty {
Count = 123
},
InputProcessingConfiguration = new InputProcessingConfigurationProperty {
InputLambdaProcessor = new InputLambdaProcessorProperty {
ResourceArn = "resourceArn"
}
},
InputSchema = new InputSchemaProperty {
RecordColumns = new [] { new RecordColumnProperty {
Mapping = "mapping",
Name = "name",
SqlType = "sqlType"
} },
RecordEncoding = "recordEncoding",
RecordFormat = new RecordFormatProperty {
MappingParameters = new MappingParametersProperty {
CsvMappingParameters = new CSVMappingParametersProperty {
RecordColumnDelimiter = "recordColumnDelimiter",
RecordRowDelimiter = "recordRowDelimiter"
},
JsonMappingParameters = new JSONMappingParametersProperty {
RecordRowPath = "recordRowPath"
}
},
RecordFormatType = "recordFormatType"
}
},
KinesisFirehoseInput = new KinesisFirehoseInputProperty {
ResourceArn = "resourceArn"
},
KinesisStreamsInput = new KinesisStreamsInputProperty {
ResourceArn = "resourceArn"
},
NamePrefix = "namePrefix"
} }
},
VpcConfigurations = new [] { new VpcConfigurationProperty {
SecurityGroupIds = new [] { "securityGroupIds" },
SubnetIds = new [] { "subnetIds" }
} },
ZeppelinApplicationConfiguration = new ZeppelinApplicationConfigurationProperty {
CatalogConfiguration = new CatalogConfigurationProperty {
GlueDataCatalogConfiguration = new GlueDataCatalogConfigurationProperty {
DatabaseArn = "databaseArn"
}
},
CustomArtifactsConfiguration = new [] { new CustomArtifactConfigurationProperty {
ArtifactType = "artifactType",
MavenReference = new MavenReferenceProperty {
ArtifactId = "artifactId",
GroupId = "groupId",
Version = "version"
},
S3ContentLocation = new S3ContentLocationProperty {
BucketArn = "bucketArn",
FileKey = "fileKey",
ObjectVersion = "objectVersion"
}
} },
DeployAsApplicationConfiguration = new DeployAsApplicationConfigurationProperty {
S3ContentLocation = new S3ContentBaseLocationProperty {
BasePath = "basePath",
BucketArn = "bucketArn"
}
},
MonitoringConfiguration = new ZeppelinMonitoringConfigurationProperty {
LogLevel = "logLevel"
}
}
};
Synopsis
Constructors
| ApplicationConfigurationProperty() | Specifies the creation parameters for a Managed Service for Apache Flink application. |
Properties
| ApplicationCodeConfiguration | The code location and type parameters for a Managed Service for Apache Flink application. |
| ApplicationEncryptionConfiguration | The configuration to manage encryption at rest. |
| ApplicationSnapshotConfiguration | Describes whether snapshots are enabled for a Managed Service for Apache Flink application. |
| ApplicationSystemRollbackConfiguration | Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application. |
| EnvironmentProperties | Describes execution properties for a Managed Service for Apache Flink application. |
| FlinkApplicationConfiguration | The creation and update parameters for a Managed Service for Apache Flink application. |
| SqlApplicationConfiguration | The creation and update parameters for a SQL-based Kinesis Data Analytics application. |
| VpcConfigurations | The array of descriptions of VPC configurations available to the application. |
| ZeppelinApplicationConfiguration | The configuration parameters for a Kinesis Data Analytics Studio notebook. |
Constructors
ApplicationConfigurationProperty()
Specifies the creation parameters for a Managed Service for Apache Flink application.
public ApplicationConfigurationProperty()
Remarks
ExampleMetadata: fixture=_generated
Examples
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
using Amazon.CDK.CfnPropertyMixins.AWS.KinesisAnalyticsV2;
var applicationConfigurationProperty = new ApplicationConfigurationProperty {
ApplicationCodeConfiguration = new ApplicationCodeConfigurationProperty {
CodeContent = new CodeContentProperty {
S3ContentLocation = new S3ContentLocationProperty {
BucketArn = "bucketArn",
FileKey = "fileKey",
ObjectVersion = "objectVersion"
},
TextContent = "textContent",
ZipFileContent = "zipFileContent"
},
CodeContentType = "codeContentType"
},
ApplicationEncryptionConfiguration = new ApplicationEncryptionConfigurationProperty {
KeyId = "keyId",
KeyType = "keyType"
},
ApplicationSnapshotConfiguration = new ApplicationSnapshotConfigurationProperty {
SnapshotsEnabled = false
},
ApplicationSystemRollbackConfiguration = new ApplicationSystemRollbackConfigurationProperty {
RollbackEnabled = false
},
EnvironmentProperties = new EnvironmentPropertiesProperty {
PropertyGroups = new [] { new PropertyGroupProperty {
PropertyGroupId = "propertyGroupId",
PropertyMap = new Dictionary<string, string> {
{ "propertyMapKey", "propertyMap" }
}
} }
},
FlinkApplicationConfiguration = new FlinkApplicationConfigurationProperty {
CheckpointConfiguration = new CheckpointConfigurationProperty {
CheckpointingEnabled = false,
CheckpointInterval = 123,
ConfigurationType = "configurationType",
MinPauseBetweenCheckpoints = 123
},
MonitoringConfiguration = new MonitoringConfigurationProperty {
ConfigurationType = "configurationType",
LogLevel = "logLevel",
MetricsLevel = "metricsLevel"
},
ParallelismConfiguration = new ParallelismConfigurationProperty {
AutoScalingEnabled = false,
ConfigurationType = "configurationType",
Parallelism = 123,
ParallelismPerKpu = 123
}
},
SqlApplicationConfiguration = new SqlApplicationConfigurationProperty {
Inputs = new [] { new InputProperty {
InputParallelism = new InputParallelismProperty {
Count = 123
},
InputProcessingConfiguration = new InputProcessingConfigurationProperty {
InputLambdaProcessor = new InputLambdaProcessorProperty {
ResourceArn = "resourceArn"
}
},
InputSchema = new InputSchemaProperty {
RecordColumns = new [] { new RecordColumnProperty {
Mapping = "mapping",
Name = "name",
SqlType = "sqlType"
} },
RecordEncoding = "recordEncoding",
RecordFormat = new RecordFormatProperty {
MappingParameters = new MappingParametersProperty {
CsvMappingParameters = new CSVMappingParametersProperty {
RecordColumnDelimiter = "recordColumnDelimiter",
RecordRowDelimiter = "recordRowDelimiter"
},
JsonMappingParameters = new JSONMappingParametersProperty {
RecordRowPath = "recordRowPath"
}
},
RecordFormatType = "recordFormatType"
}
},
KinesisFirehoseInput = new KinesisFirehoseInputProperty {
ResourceArn = "resourceArn"
},
KinesisStreamsInput = new KinesisStreamsInputProperty {
ResourceArn = "resourceArn"
},
NamePrefix = "namePrefix"
} }
},
VpcConfigurations = new [] { new VpcConfigurationProperty {
SecurityGroupIds = new [] { "securityGroupIds" },
SubnetIds = new [] { "subnetIds" }
} },
ZeppelinApplicationConfiguration = new ZeppelinApplicationConfigurationProperty {
CatalogConfiguration = new CatalogConfigurationProperty {
GlueDataCatalogConfiguration = new GlueDataCatalogConfigurationProperty {
DatabaseArn = "databaseArn"
}
},
CustomArtifactsConfiguration = new [] { new CustomArtifactConfigurationProperty {
ArtifactType = "artifactType",
MavenReference = new MavenReferenceProperty {
ArtifactId = "artifactId",
GroupId = "groupId",
Version = "version"
},
S3ContentLocation = new S3ContentLocationProperty {
BucketArn = "bucketArn",
FileKey = "fileKey",
ObjectVersion = "objectVersion"
}
} },
DeployAsApplicationConfiguration = new DeployAsApplicationConfigurationProperty {
S3ContentLocation = new S3ContentBaseLocationProperty {
BasePath = "basePath",
BucketArn = "bucketArn"
}
},
MonitoringConfiguration = new ZeppelinMonitoringConfigurationProperty {
LogLevel = "logLevel"
}
}
};
Properties
ApplicationCodeConfiguration
The code location and type parameters for a Managed Service for Apache Flink application.
public object? ApplicationCodeConfiguration { get; set; }
Property Value
Remarks
Type union: either IResolvable or CfnApplicationPropsMixin.IApplicationCodeConfigurationProperty
ApplicationEncryptionConfiguration
The configuration to manage encryption at rest.
public object? ApplicationEncryptionConfiguration { get; set; }
Property Value
Remarks
Type union: either IResolvable or CfnApplicationPropsMixin.IApplicationEncryptionConfigurationProperty
ApplicationSnapshotConfiguration
Describes whether snapshots are enabled for a Managed Service for Apache Flink application.
public object? ApplicationSnapshotConfiguration { get; set; }
Property Value
Remarks
Type union: either IResolvable or CfnApplicationPropsMixin.IApplicationSnapshotConfigurationProperty
ApplicationSystemRollbackConfiguration
Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application.
public object? ApplicationSystemRollbackConfiguration { get; set; }
Property Value
Remarks
Type union: either IResolvable or CfnApplicationPropsMixin.IApplicationSystemRollbackConfigurationProperty
EnvironmentProperties
Describes execution properties for a Managed Service for Apache Flink application.
public object? EnvironmentProperties { get; set; }
Property Value
Remarks
Type union: either IResolvable or CfnApplicationPropsMixin.IEnvironmentPropertiesProperty
FlinkApplicationConfiguration
The creation and update parameters for a Managed Service for Apache Flink application.
public object? FlinkApplicationConfiguration { get; set; }
Property Value
Remarks
Type union: either IResolvable or CfnApplicationPropsMixin.IFlinkApplicationConfigurationProperty
SqlApplicationConfiguration
The creation and update parameters for a SQL-based Kinesis Data Analytics application.
public object? SqlApplicationConfiguration { get; set; }
Property Value
Remarks
Type union: either IResolvable or CfnApplicationPropsMixin.ISqlApplicationConfigurationProperty
VpcConfigurations
The array of descriptions of VPC configurations available to the application.
public object? VpcConfigurations { get; set; }
Property Value
Remarks
Type union: either IResolvable or (either IResolvable or CfnApplicationPropsMixin.IVpcConfigurationProperty)[]
ZeppelinApplicationConfiguration
The configuration parameters for a Kinesis Data Analytics Studio notebook.
public object? ZeppelinApplicationConfiguration { get; set; }
Property Value
Remarks
Type union: either IResolvable or CfnApplicationPropsMixin.IZeppelinApplicationConfigurationProperty