tchivs opened a new pull request, #4202:
URL: https://github.com/apache/flink-cdc/pull/4202
## What is the purpose of the pull request
This PR adds metadata column support for the PostgreSQL Pipeline Connector,
enabling users to access metadata information such as operation timestamp,
database name, schema name, and table name in their data pipelines.
## Brief change log
- Add 4 metadata column implementations:
- `OpTsMetadataColumn`: Operation timestamp metadata
- `DatabaseNameMetadataColumn`: Database name metadata
- `SchemaNameMetadataColumn`: Schema name metadata
- `TableNameMetadataColumn`: Table name metadata
- Update `PostgresDataSource` to support metadata columns via
`supportedMetadataColumns()` method
- Add comprehensive E2E test `testAllMetadataColumns()` in
`PostgresFullTypesITCase`
- Update documentation for both English and Chinese versions
## Verifying this change
This change added tests and can be verified as follows:
- Added `testAllMetadataColumns()` E2E test in `PostgresFullTypesITCase`
- Test verifies metadata columns in both snapshot and incremental phases
- All tests pass successfully
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: no
- The serializers: no
- The runtime per-record code paths: no
- Anything that affects deployment or recovery: no
- Does this pull request introduce a new feature: yes
## Documentation
- Does this pull request introduce a new feature: yes
- If yes, how is the feature documented: docs
--
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]
