protected KinesisFirehoseDynamicSink()

in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicSink.java [60:86]

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

    protected KinesisFirehoseDynamicSink(
            @Nullable Integer maxBatchSize,
            @Nullable Integer maxInFlightRequests,
            @Nullable Integer maxBufferedRequests,
            @Nullable Long maxBufferSizeInBytes,
            @Nullable Long maxTimeInBufferMS,
            @Nullable Boolean failOnError,
            @Nullable DataType consumedDataType,
            String deliveryStream,
            @Nullable Properties firehoseClientProperties,
            EncodingFormat<SerializationSchema<RowData>> encodingFormat) {
        super(
                maxBatchSize,
                maxInFlightRequests,
                maxBufferedRequests,
                maxBufferSizeInBytes,
                maxTimeInBufferMS);
        this.failOnError = failOnError;
        this.firehoseClientProperties = firehoseClientProperties;
        this.consumedDataType =
                Preconditions.checkNotNull(consumedDataType, "Consumed data type must not be null");
        this.deliveryStream =
                Preconditions.checkNotNull(
                        deliveryStream, "Firehose Delivery stream name must not be null");
        this.encodingFormat =
                Preconditions.checkNotNull(encodingFormat, "Encoding format must not be null");
    }