private CassandraSinkBaseConfig()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseConfig.java [53:67]

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

    private CassandraSinkBaseConfig(
            int maxConcurrentRequests,
            Duration maxConcurrentRequestsTimeout,
            boolean ignoreNullFields) {
        Preconditions.checkArgument(
                maxConcurrentRequests > 0, "Max concurrent requests is expected to be positive");
        Preconditions.checkNotNull(
                maxConcurrentRequestsTimeout, "Max concurrent requests timeout cannot be null");
        Preconditions.checkArgument(
                !maxConcurrentRequestsTimeout.isNegative(),
                "Max concurrent requests timeout is expected to be positive");
        this.maxConcurrentRequests = maxConcurrentRequests;
        this.maxConcurrentRequestsTimeout = maxConcurrentRequestsTimeout;
        this.ignoreNullFields = ignoreNullFields;
    }