public SourceReader createReader()

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

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

    public SourceReader<OUT, CassandraSplit> createReader(SourceReaderContext readerContext) {
        return new CassandraSourceReaderFactory<OUT>()
                .create(
                        readerContext,
                        clusterBuilder,
                        pojoClass,
                        query,
                        keyspace,
                        table,
                        mapperOptions);
    }