private KuduReaderConfig()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/reader/KuduReaderConfig.java [46:67]

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

    private KuduReaderConfig(
            String masters,
            int rowLimit,
            long splitSizeBytes,
            int batchSizeBytes,
            long scanRequestTimeout,
            boolean prefetching,
            long keepAlivePeriodMs,
            ReplicaSelection replicaSelection) {

        this.masters = checkNotNull(masters, "Kudu masters cannot be null");
        this.rowLimit = checkNotNull(rowLimit, "Kudu rowLimit cannot be null");
        this.splitSizeBytes = checkNotNull(splitSizeBytes, "Kudu split size cannot be null");
        this.batchSizeBytes = checkNotNull(batchSizeBytes, "Kudu batch size cannot be null");
        this.scanRequestTimeout =
                checkNotNull(scanRequestTimeout, "Kudu scan request timeout cannot be null");
        this.prefetching = checkNotNull(prefetching, "Kudu prefetching cannot be null");
        this.keepAlivePeriodMs =
                checkNotNull(keepAlivePeriodMs, "Kudu keep alive period ms cannot be null");
        this.replicaSelection =
                checkNotNull(replicaSelection, "Kudu replica selection cannot be null");
    }