private void createKinesisFirehose()

in cdk/src/main/java/com/amazonaws/services/kinesisanalytics/AmazonKinesisDataAnalyticsApacheFlinkServerSentEventsSseCdkStack.java [147:161]

• 15 lines of code
• 1 McCabe index (conditional complexity)

    private void createKinesisFirehose() {
        final S3Bucket s3DestinationBucket = S3Bucket.Builder.create(s3StorageBucket)
                .bufferingInterval(Duration.seconds(60))
                .dataOutputPrefix(s3StoragePrefixParam.getValueAsString())
                .errorOutputPrefix(s3StorageErrorPrefixParam.getValueAsString())
                .bufferingSize(Size.mebibytes(5))
                .build();
        DeliveryStream.Builder.create(this, "KinesisFirehoseS3Delivery")
                .sourceStream(outputDataStream)
                .encryption(software.amazon.awscdk.services.kinesisfirehose.StreamEncryption.UNENCRYPTED)
                .destinations(List.of(
                        s3DestinationBucket
                ))
                .build();
    }