Interface CfnApplicationV2.IApplicationConfigurationProperty
Specifies the creation parameters for a Managed Service for Apache Flink application.
Namespace: Amazon.CDK.AWS.KinesisAnalytics
Assembly: Amazon.CDK.Lib.dll
Syntax (csharp)
public interface IApplicationConfigurationProperty
Syntax (vb)
Public Interface 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.AWS.KinesisAnalytics;
var applicationConfigurationProperty = new ApplicationConfigurationProperty {
ApplicationCodeConfiguration = new ApplicationCodeConfigurationProperty {
CodeContent = new CodeContentProperty {
S3ContentLocation = new S3ContentLocationProperty {
BucketArn = "bucketArn",
FileKey = "fileKey",
// the properties below are optional
ObjectVersion = "objectVersion"
},
TextContent = "textContent",
ZipFileContent = "zipFileContent"
},
CodeContentType = "codeContentType"
},
ApplicationSnapshotConfiguration = new ApplicationSnapshotConfigurationProperty {
SnapshotsEnabled = false
},
EnvironmentProperties = new EnvironmentPropertiesProperty {
PropertyGroups = new [] { new PropertyGroupProperty {
PropertyGroupId = "propertyGroupId",
PropertyMap = new Dictionary<string, string> {
{ "propertyMapKey", "propertyMap" }
}
} }
},
FlinkApplicationConfiguration = new FlinkApplicationConfigurationProperty {
CheckpointConfiguration = new CheckpointConfigurationProperty {
ConfigurationType = "configurationType",
// the properties below are optional
CheckpointingEnabled = false,
CheckpointInterval = 123,
MinPauseBetweenCheckpoints = 123
},
MonitoringConfiguration = new MonitoringConfigurationProperty {
ConfigurationType = "configurationType",
// the properties below are optional
LogLevel = "logLevel",
MetricsLevel = "metricsLevel"
},
ParallelismConfiguration = new ParallelismConfigurationProperty {
ConfigurationType = "configurationType",
// the properties below are optional
AutoScalingEnabled = false,
Parallelism = 123,
ParallelismPerKpu = 123
}
},
SqlApplicationConfiguration = new SqlApplicationConfigurationProperty {
Inputs = new [] { new InputProperty {
InputSchema = new InputSchemaProperty {
RecordColumns = new [] { new RecordColumnProperty {
Name = "name",
SqlType = "sqlType",
// the properties below are optional
Mapping = "mapping"
} },
RecordFormat = new RecordFormatProperty {
RecordFormatType = "recordFormatType",
// the properties below are optional
MappingParameters = new MappingParametersProperty {
CsvMappingParameters = new CSVMappingParametersProperty {
RecordColumnDelimiter = "recordColumnDelimiter",
RecordRowDelimiter = "recordRowDelimiter"
},
JsonMappingParameters = new JSONMappingParametersProperty {
RecordRowPath = "recordRowPath"
}
}
},
// the properties below are optional
RecordEncoding = "recordEncoding"
},
NamePrefix = "namePrefix",
// the properties below are optional
InputParallelism = new InputParallelismProperty {
Count = 123
},
InputProcessingConfiguration = new InputProcessingConfigurationProperty {
InputLambdaProcessor = new InputLambdaProcessorProperty {
ResourceArn = "resourceArn"
}
},
KinesisFirehoseInput = new KinesisFirehoseInputProperty {
ResourceArn = "resourceArn"
},
KinesisStreamsInput = new KinesisStreamsInputProperty {
ResourceArn = "resourceArn"
}
} }
},
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",
// the properties below are optional
MavenReference = new MavenReferenceProperty {
ArtifactId = "artifactId",
GroupId = "groupId",
Version = "version"
},
S3ContentLocation = new S3ContentLocationProperty {
BucketArn = "bucketArn",
FileKey = "fileKey",
// the properties below are optional
ObjectVersion = "objectVersion"
}
} },
DeployAsApplicationConfiguration = new DeployAsApplicationConfigurationProperty {
S3ContentLocation = new S3ContentBaseLocationProperty {
BucketArn = "bucketArn",
// the properties below are optional
BasePath = "basePath"
}
},
MonitoringConfiguration = new ZeppelinMonitoringConfigurationProperty {
LogLevel = "logLevel"
}
}
};
Synopsis
Properties
ApplicationCodeConfiguration | The code location and type parameters for a Managed Service for Apache Flink application. |
ApplicationSnapshotConfiguration | Describes whether snapshots 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. |
Properties
ApplicationCodeConfiguration
The code location and type parameters for a Managed Service for Apache Flink application.
virtual object ApplicationCodeConfiguration { get; }
Property Value
System.Object
Remarks
ApplicationSnapshotConfiguration
Describes whether snapshots are enabled for a Managed Service for Apache Flink application.
virtual object ApplicationSnapshotConfiguration { get; }
Property Value
System.Object
Remarks
EnvironmentProperties
Describes execution properties for a Managed Service for Apache Flink application.
virtual object EnvironmentProperties { get; }
Property Value
System.Object
Remarks
FlinkApplicationConfiguration
The creation and update parameters for a Managed Service for Apache Flink application.
virtual object FlinkApplicationConfiguration { get; }
Property Value
System.Object
Remarks
SqlApplicationConfiguration
The creation and update parameters for a SQL-based Kinesis Data Analytics application.
virtual object SqlApplicationConfiguration { get; }
Property Value
System.Object
Remarks
VpcConfigurations
The array of descriptions of VPC configurations available to the application.
virtual object VpcConfigurations { get; }
Property Value
System.Object
Remarks
ZeppelinApplicationConfiguration
The configuration parameters for a Kinesis Data Analytics Studio notebook.
virtual object ZeppelinApplicationConfiguration { get; }
Property Value
System.Object