Migrate JDBC plugins to page source API

[raunaqmorarka]

Description

Changes JDBC connectors to produce pages rather a cursor.
This allows JDBC connectors to benefit from dynamic row filtering and columnar filter evaluation optimizations.
We're also able to use io.trino.plugin.jdbc.JdbcPageSource#isBlocked to yield when waiting for results from source DB.
RemoteQueryCancellation is removed because all jdbc queries are now executed
on a separate thread pool which allows remote query cancellation.

Additional context and related issues

I made a JMH benchmark at raunaqmorarka@6e015db
This assesses the performance of a highly selective filter (~1% selectivity) on a varchar column that is in front of another 7 varchar columns.

BenchmarkScanFilterAndProjectOperator.benchmarkColumnOriented
(columnCount)  (columnarFilterEvaluationEnabled)  (positionsPerPage)   (type)  (useRecordCursor)   Mode  Cnt    Score   Error  Units
            8                              false                1024  varchar               true  thrpt   20   90.872 ± 1.197  ops/s
            8                              false                1024  varchar              false  thrpt   20  113.378 ± 1.033  ops/s
            8                               true                1024  varchar              false  thrpt   20  140.283 ± 0.835  ops/s\

The cursor interface version is worse both with and without columnar filter evaluation enabled.

Release notes

( ) This is not user-visible or is docs only, and no release notes are required.
( ) Release notes are required. Please propose a release note for me.
(x) Release notes are required, with the following suggested text:

## ClickHouse, Druid, DuckDb, Exasol, Ignite, MariaDb, MySql, Oracle, Postgresql, Redshift, Singlestore, SnowFlake, SQL server, Vertica 
* Improve performance of selective joins for federated queries. ({issue}`25123`)

[raunaqmorarka]

postgresql unpartitioned sf10.pdf
postgresql partitioned sf10.pdf

TPCH is mostly the same, TPCDS has some gains

[chenjian2664]

When there is SQLException failure, there may be a little difference.

if (e.getCause() instanceof SQLException cause) {
    SQLException sqlException = new SQLException(cause.getMessage(), cause.getSQLState(), cause.getErrorCode(), e);
    if (cause.getNextException() != null) {
        sqlException.setNextException(cause.getNextException());
    }
    throw sqlException;
}

[Copilot]

Pull Request Overview

This PR migrates JDBC connectors from a recordset-based implementation to the new page source API in order to enable dynamic row filtering and improved columnar filter evaluation optimizations. Key changes include:

• Migrating connector and split manager classes to use ConnectorPageSourceProvider instead of ConnectorRecordSetProvider.
• Updating tests to iterate over SourcePage rather than using a RecordCursor.
• Removing RemoteQueryCancellation modules and related test files.

Reviewed Changes

Copilot reviewed 18 out of 18 changed files in this pull request and generated no comments.

Show a summary per file

File	Description
plugin/trino-redshift/src/main/java/io/trino/plugin/redshift/RedshiftUnloadConnector.java	Updated constructor parameter to use jdbcPageSourceProvider.
plugin/trino-redshift/src/main/java/io/trino/plugin/redshift/RedshiftSplitManager.java	Changed annotation from @ForRecordCursor to @ForJdbcClient for the executor.
plugin/trino-redshift/src/main/java/io/trino/plugin/redshift/RedshiftPageSourceProvider.java	Replaced RecordPageSource with jdbcPageSourceProvider.createPageSource.
plugin/trino-redshift/src/main/java/io/trino/plugin/redshift/RedshiftClientModule.java	Removed RemoteQueryCancellationModule installation.
plugin/trino-postgresql/src/main/java/io/trino/plugin/postgresql/PostgreSqlClientModule.java	Removed RemoteQueryCancellationModule installation.
plugin/trino-base-jdbc/src/test/java/io/trino/plugin/jdbc/TestJdbcPageSourceProvider.java	Updated test methods to use page source and adjusted iteration accordingly.
plugin/trino-base-jdbc/src/test/java/io/trino/plugin/jdbc/TestJdbcPageSource.java	Updated tests to use JdbcPageSource and Surface new API validated through SourcePage iteration.
Others (modules, configurations, removed files)	Cleaned up RemoteQueryCancellation and deprecated recordset implementations.

Comments suppressed due to low confidence (2)

plugin/trino-redshift/src/main/java/io/trino/plugin/redshift/RedshiftPageSourceProvider.java:69

• The error message still refers to 'recordSetProvider' instead of 'jdbcPageSourceProvider'. Please update the message accordingly.

this.jdbcPageSourceProvider = requireNonNull(jdbcPageSourceProvider, "recordSetProvider is null");

plugin/trino-base-jdbc/src/test/java/io/trino/plugin/jdbc/TestJdbcPageSourceProvider.java:110

• The failure message should be updated to reference 'pageSource' instead of 'recordSet' to reflect the new API.

assertThat(pageSource).withFailMessage("recordSet is null").isNotNull();

[wendigo]

@raunaqmorarka Are benchmarks ok now?

[raunaqmorarka]

@raunaqmorarka Are benchmarks ok now?

Yes, i've updated my initial results, there aren't significant regressions any more

[sajjoseph]

@sourcery-ai review

[sourcery-ai]

Hi @sajjoseph! 👋

Only authors and team members can run @sourcery-ai commands on public repos.