public SplitsGenerator()

in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java [51:64]

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

    public SplitsGenerator(
            CassandraPartitioner partitioner,
            Session session,
            String keyspace,
            String table,
            int parallelism,
            long maxSplitMemorySize) {
        this.partitioner = partitioner;
        this.session = session;
        this.keyspace = keyspace;
        this.table = table;
        this.parallelism = parallelism;
        this.maxSplitMemorySize = maxSplitMemorySize;
    }