syhily opened a new pull request, #35:
URL: https://github.com/apache/flink-connector-pulsar/pull/35
## Purpose of the change
This PR will make the Pulsar serve as the Flink catalog backend. It will
expose the Pulsar's namespace as the Flink's database, the Pulsar's topic as
the Flink's table. You can easily create any tables and databases on Pulsar.
The tables created by Flink can be consumed by other Pulsar clients with a
valid schema check.
## Brief change log
- Support both `Duration` and numeric time in `PulsarConfiguration` class,
which make the existing config options can be configured with a time str in
Table API.
- Alter all the existing time related config options to use `useDuration`
method.
- Initial `PulsarCatalog` implementation with new config model and schema
translator and etc.
## Verifying this change
This change doesn't contains any tests, it's a initial implementation which
won't be used by any user. We will add tests in upcoming PRs.
## Significant changes
- [x] Dependencies have been added or upgraded
- [ ] Public API has been changed (Public API is any class annotated with
`@Public(Evolving)`)
- [ ] Serializers have been changed
- [x] New feature has been introduced
- If yes, how is this documented? (not documented)
--
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]
