slinkydeveloper opened a new pull request #18283:
URL: https://github.com/apache/flink/pull/18283
## What is the purpose of the change
This PR adds the required new APIs to expose merging the options from the
catalog table, when restoring a plan.
## Brief change log
* Added `DynamicTableFactory.Context#mergeableOptions` to expose options
from the catalog table.
* Added `FormatFactory` as base interface for `DecodingFormatFactory` and
`EncodingFormatFactory`. Added `FormatFactory#mergeableOptions()` to
declaratively define which options can be merged from the catalog table.
* Added `FactoryUtil#forwardOptions` to perform the merge
* Added some validation code to verify the catalog table is correct
* Show how to use the new APIs in json and connector-kafka
## Verifying this change
Added tests in `FactoryUtil` to verify the merging process.
## 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)`: yes
## Documentation
- Does this pull request introduce a new feature? yes
- If yes, how is the feature documented? JavaDocs
--
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]
