Use the standard Trino JDBC provider and remove YDB merge sinks - #261
Conversation
|
Кирилл, окончательный PR готов — ревью 1/1 среди готовых, после уже merged JDBC #260. Используются штатные JdbcPageSinkProvider и JdbcMergeSink Trino. YdbPageSinkProvider, YdbMergeSink и YdbRetryUtils удалены; production/test wiring подключены через стандартный интерфейс. Размер +17/−614=631 строка, 8 файлов — разрешённое тобой исключение из лимита для этой очистки. Head:3c7d813d7df953e51ac4220dacba7c2063a633b7. Независимое ревью exactSHA и локальные JDK25 compile/test-compile прошли. Финальный полный CI: https://github.com/ydb-platform/ydb-java-dialects/actions/runs/34598335627 — 307 тестов,222 passed,85 skipped,0 failures,0 errors. Это результат версии с удалёнными классами. Локальный Docker недоступен; runtime подтверждён CI. Операции могут коммититься отдельно; общей атомарности MERGE не заявляем. Оставшихся незамерженных зависимостей нет. Даты последуют отдельно. Автоматического merge не будет; комментарий обновлён без нового @-пинга. |
Uses Trino 483's default
JdbcPageSinkProviderandJdbcMergeSinkfor YDB writes.YdbConnectornow receivesConnectorPageSinkProviderthrough the binding already supplied byJdbcModule; production and test modules no longer bind a custom provider.Deletes
YdbPageSinkProvider,YdbMergeSink, andYdbRetryUtils. The connector no longer owns MERGE buffering or transaction replay. Existing ordered primary-key metadata, one writer task, and rejection of query/task retries remain unchanged. The roadmap and client comment reflect the standard sink behavior.INSERT, DELETE, and UPDATE can commit batches through separate connections. Whole-MERGE atomicity and rollback across all operation sinks are not provided. No capability changes, new PK guard, retry wrapper, or test exclusions are added.
The complete diff against main is 17 additions and 614 deletions (631 total) across 8 files. The user explicitly approved exceeding the usual 200-line limit for this removal and wiring change.
Validation for final revision
3c7d813d7df953e51ac4220dacba7c2063a633b7:163a2815376c50041811469eb92113e8c9f88290with main6943891bcc45232e14be33f51519f6b3ed0796c9.