public CassandraSource()

in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java [118:141]

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

    public CassandraSource(
            ClusterBuilder clusterBuilder,
            long maxSplitMemorySize,
            Class<OUT> pojoClass,
            String query,
            MapperOptions mapperOptions) {
        checkNotNull(clusterBuilder, "ClusterBuilder required but not provided");
        checkNotNull(pojoClass, "POJO class required but not provided");
        checkNotNull(query, "query required but not provided");
        checkState(
                maxSplitMemorySize >= MIN_SPLIT_MEMORY_SIZE,
                "Defined maxSplitMemorySize (%s) is below minimum (%s)",
                maxSplitMemorySize,
                MIN_SPLIT_MEMORY_SIZE);
        this.maxSplitMemorySize = maxSplitMemorySize;
        final Matcher queryMatcher = checkQueryValidity(query);
        this.query = query;
        this.keyspace = queryMatcher.group(1);
        this.table = queryMatcher.group(2);
        this.clusterBuilder = clusterBuilder;
        ClosureCleaner.clean(clusterBuilder, ExecutionConfig.ClosureCleanerLevel.RECURSIVE, true);
        this.pojoClass = pojoClass;
        this.mapperOptions = mapperOptions;
    }