private CassandraEnumeratorState prepareSplits()

in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraSplitEnumerator.java [79:90]

12 lines of code
2 McCabe index (conditional complexity)


    private CassandraEnumeratorState prepareSplits() {
        final int parallelism = enumeratorContext.currentParallelism();
        final String partitionerName = cluster.getMetadata().getPartitioner();
        final SplitsGenerator.CassandraPartitioner partitioner =
                partitionerName.contains(MURMUR3PARTITIONER.getClassName())
                        ? MURMUR3PARTITIONER
                        : RANDOMPARTITIONER;
        final SplitsGenerator splitsGenerator =
                new SplitsGenerator(
                        partitioner, session, keyspace, table, parallelism, maxSplitMemorySize);
        return splitsGenerator.prepareSplits();
    }