public KinesisDynamicSource()

in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicSource.java [118:146]

28 lines of code
1 McCabe index (conditional complexity)


    public KinesisDynamicSource(
            DataType physicalDataType,
            String stream,
            String shardAssignerIdentifier,
            Properties consumerProperties,
            DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
            DataType producedDataType,
            List<Metadata> requestedMetadataFields) {

        this.physicalDataType =
                Preconditions.checkNotNull(
                        physicalDataType, "Physical data type must not be null.");
        this.stream = Preconditions.checkNotNull(stream, "Stream must not be null.");
        this.shardAssignerIdentifier =
                Preconditions.checkNotNull(
                        shardAssignerIdentifier, "Shard assigner must not be null.");
        this.consumerProperties =
                Preconditions.checkNotNull(
                        consumerProperties,
                        "Properties for the Flink Kinesis consumer must not be null.");
        this.decodingFormat =
                Preconditions.checkNotNull(decodingFormat, "Decoding format must not be null.");
        this.producedDataType =
                Preconditions.checkNotNull(
                        producedDataType, "Produced data type must not be null.");
        this.requestedMetadataFields =
                Preconditions.checkNotNull(
                        requestedMetadataFields, "Requested metadata fields must not be null.");
    }