interface ApplicationCodeConfig
Language | Type name |
---|---|
.NET | Amazon.CDK.AWS.KinesisAnalyticsFlink.ApplicationCodeConfig |
Java | software.amazon.awscdk.services.kinesis.analytics.flink.ApplicationCodeConfig |
Python | aws_cdk.aws_kinesisanalytics_flink.ApplicationCodeConfig |
TypeScript (source) | @aws-cdk/aws-kinesisanalytics-flink » ApplicationCodeConfig |
Obtainable from
Application
.bind()
The return type of {@link ApplicationCode.bind}. This represents CloudFormation configuration and an s3 bucket holding the Flink application JAR file.
Example
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as kinesisanalytics_flink from '@aws-cdk/aws-kinesisanalytics-flink';
import * as s3 from '@aws-cdk/aws-s3';
declare const bucket: s3.Bucket;
const applicationCodeConfig: kinesisanalytics_flink.ApplicationCodeConfig = {
applicationCodeConfigurationProperty: {
applicationCodeConfiguration: {
codeContent: {
s3ContentLocation: {
bucketArn: 'bucketArn',
fileKey: 'fileKey',
// the properties below are optional
objectVersion: 'objectVersion',
},
textContent: 'textContent',
zipFileContent: 'zipFileContent',
},
codeContentType: 'codeContentType',
},
applicationSnapshotConfiguration: {
snapshotsEnabled: false,
},
environmentProperties: {
propertyGroups: [{
propertyGroupId: 'propertyGroupId',
propertyMap: {
propertyMapKey: 'propertyMap',
},
}],
},
flinkApplicationConfiguration: {
checkpointConfiguration: {
configurationType: 'configurationType',
// the properties below are optional
checkpointingEnabled: false,
checkpointInterval: 123,
minPauseBetweenCheckpoints: 123,
},
monitoringConfiguration: {
configurationType: 'configurationType',
// the properties below are optional
logLevel: 'logLevel',
metricsLevel: 'metricsLevel',
},
parallelismConfiguration: {
configurationType: 'configurationType',
// the properties below are optional
autoScalingEnabled: false,
parallelism: 123,
parallelismPerKpu: 123,
},
},
sqlApplicationConfiguration: {
inputs: [{
inputSchema: {
recordColumns: [{
name: 'name',
sqlType: 'sqlType',
// the properties below are optional
mapping: 'mapping',
}],
recordFormat: {
recordFormatType: 'recordFormatType',
// the properties below are optional
mappingParameters: {
csvMappingParameters: {
recordColumnDelimiter: 'recordColumnDelimiter',
recordRowDelimiter: 'recordRowDelimiter',
},
jsonMappingParameters: {
recordRowPath: 'recordRowPath',
},
},
},
// the properties below are optional
recordEncoding: 'recordEncoding',
},
namePrefix: 'namePrefix',
// the properties below are optional
inputParallelism: {
count: 123,
},
inputProcessingConfiguration: {
inputLambdaProcessor: {
resourceArn: 'resourceArn',
},
},
kinesisFirehoseInput: {
resourceArn: 'resourceArn',
},
kinesisStreamsInput: {
resourceArn: 'resourceArn',
},
}],
},
vpcConfigurations: [{
securityGroupIds: ['securityGroupIds'],
subnetIds: ['subnetIds'],
}],
zeppelinApplicationConfiguration: {
catalogConfiguration: {
glueDataCatalogConfiguration: {
databaseArn: 'databaseArn',
},
},
customArtifactsConfiguration: [{
artifactType: 'artifactType',
// the properties below are optional
mavenReference: {
artifactId: 'artifactId',
groupId: 'groupId',
version: 'version',
},
s3ContentLocation: {
bucketArn: 'bucketArn',
fileKey: 'fileKey',
// the properties below are optional
objectVersion: 'objectVersion',
},
}],
deployAsApplicationConfiguration: {
s3ContentLocation: {
bucketArn: 'bucketArn',
// the properties below are optional
basePath: 'basePath',
},
},
monitoringConfiguration: {
logLevel: 'logLevel',
},
},
},
bucket: bucket,
};
Properties
Name | Type | Description |
---|---|---|
application | Application | Low-level Cloudformation ApplicationConfigurationProperty. |
bucket | IBucket | S3 Bucket that stores the Flink application code. |
applicationCodeConfigurationProperty
Type:
Application
Low-level Cloudformation ApplicationConfigurationProperty.
bucket
Type:
IBucket
S3 Bucket that stores the Flink application code.