private void advance()

in src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java [74:87]

• 14 lines of code
• 3 McCabe index (conditional complexity)

    private void advance() {
        if (current == null) {
            throw new RuntimeException("Current is null, should not invoke advance");
        }
        try {
            completedBytes += current.getCompletedBytes();
            current.close();
        } catch (IOException e) {
            current = null;
            close();
            throw new RuntimeException("error happens while advance and close old page source.");
        }
        current = pageSourceQueue.poll();
    }