public void handleSplitRequest()

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

13 lines of code
2 McCabe index (conditional complexity)


    public void handleSplitRequest(int subtaskId, @Nullable String requesterHostname) {
        checkReaderRegistered(subtaskId);
        final CassandraSplit cassandraSplit = state.getNextSplit();
        if (cassandraSplit != null) {
            LOG.info("Assigning splits to reader {}", subtaskId);
            enumeratorContext.assignSplit(cassandraSplit, subtaskId);
        } else {
            LOG.info(
                    "No split assigned to reader {} because the enumerator has no unassigned split left. Sending NoMoreSplitsEvent to reader",
                    subtaskId);
            enumeratorContext.signalNoMoreSplits(subtaskId);
        }
    }