public CassandraEnumeratorState()

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

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

    public CassandraEnumeratorState(
            long numSplitsLeftToGenerate,
            BigInteger increment,
            BigInteger startToken,
            BigInteger maxToken,
            Queue<CassandraSplit> splitsToReassign) {
        this.numSplitsLeftToGenerate = numSplitsLeftToGenerate;
        this.increment = increment;
        this.startToken = startToken;
        this.maxToken = maxToken;
        this.splitsToReassign = splitsToReassign;
    }