public void close()

in src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java [90:101]

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

    public void close() {
        try {
            if (current != null) {
                current.close();
            }
            for (ConnectorPageSource source : pageSourceQueue) {
                source.close();
            }
        } catch (IOException e) {
            throw new UncheckedIOException(e);
        }
    }