public CassandraSplitEnumerator()

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

15 lines of code
2 McCabe index (conditional complexity)


    public CassandraSplitEnumerator(
            SplitEnumeratorContext<CassandraSplit> enumeratorContext,
            CassandraEnumeratorState state,
            ClusterBuilder clusterBuilder,
            Long maxSplitMemorySize,
            String keyspace,
            String table) {
        this.enumeratorContext = enumeratorContext;
        this.state = state == null ? new CassandraEnumeratorState() : state /* snapshot restore*/;
        this.cluster = clusterBuilder.getCluster();
        this.maxSplitMemorySize = maxSplitMemorySize;
        this.session = cluster.newSession();
        this.keyspace = keyspace;
        this.table = table;
    }