NixonWahome opened a new pull request, #10896:
URL: https://github.com/apache/seatunnel/pull/10896
## Purpose
Adds `tables_configs` multi-table read support to the Cassandra source
connector,
consistent with the pattern already used by Redis (#10601).
Closes #10425
## Changes
- CassandraTableConfig — new per-table config holder (cql + CatalogTable +
tableId)
- CassandraBaseOptions— extends `ConnectorCommonOptions` to inherit
`TABLE_CONFIGS`
- CassandraSource — supports both `cql` (single-table) and `tables_configs`
(multi-table);
schema discovery via `ResultSet.getColumnDefinitions()` — also fixes crash
on empty tables
- CassandraSourceFactory — `cql` is now `exclusive` with `TABLE_CONFIGS`
instead of `required`
- CassandraSourceReader — iterates all table configs, sets
`row.setTableId()` for routing
- Docs — updated English and Chinese connector docs with multi-table examples
## Test
- Reviewed implementation against the Redis multi-table source PR (#10601),
the approved blueprint for this pattern in Apache SeaTunnel
- Traced multi-table row routing through
`CatalogTableUtil.convertToMultipleRowType`
and `SeaTunnelSourceCollector` to verify `row.setTableId()` keys match the
framework's `rowTypeMap` keys by construction
- Single-table backward compatibility preserved — existing `cql` mode is
unchanged
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
