in cdk/src/main/java/com/amazonaws/services/kinesisanalytics/AmazonKinesisDataAnalyticsApacheFlinkServerSentEventsSseCdkStack.java [67:104]
private void createParameters() {
s3BucketParam = CfnParameter.Builder.create(this, "S3Bucket")
.type("String")
.description("The S3 bucket where the Amazon Kinesis Data Analytics application gets your application's JAR file")
.allowedPattern(".+")
.build();
s3StorageBucketParam = CfnParameter.Builder.create(this, "S3StorageBucket")
.type("String")
.description("The S3 bucket name used to store the server-sent events data")
.allowedPattern(".+")
.build();
s3StoragePrefixParam = CfnParameter.Builder.create(this, "S3StorageBucketPrefix")
.type("String")
.description("The prefix used when storing server-sent events data into the S3 bucket")
.defaultValue("sse-data")
.build();
s3StorageErrorPrefixParam = CfnParameter.Builder.create(this, "S3StorageBucketErrorPrefix")
.type("String")
.description("The prefix used when storing error events into the S3 bucket")
.defaultValue("sse-error")
.build();
filenameParam = CfnParameter.Builder.create(this, "FlinkApplication")
.type("String")
.description("The Apache Flink application jar filename located in the S3 bucket")
.defaultValue("amazon-kinesis-data-analytics-apache-flink-server-sent-events-1.0.0.jar")
.allowedPattern(".+")
.build();
if (!this.createVPC) {
subnetIdsParam = CfnParameter.Builder.create(this, "Subnets")
.type("List<AWS::EC2::Subnet::Id>")
.description("The subnet Ids used for the Amazon Kinesis Data Analytics application")
.build();
securityGroupIdsParam = CfnParameter.Builder.create(this, "SecurityGroups")
.type("List<AWS::EC2::SecurityGroup::Id>")
.description("The security group Ids used for the Amazon Kinesis Data Analytics application")
.build();
}
}