GitHub user beyond1920 opened a pull request:
https://github.com/apache/flink/pull/3409
[flink-5570] [Table API & SQL]Support register external catalog to table
environment
This pr aims to support register external catalog to TableEnvironment.
The pr contains two commits, the first one is about
https://issues.apache.org/jira/browse/FLINK-5568, it's content is as same as
(https://github.com/apache/flink/pull/3406).
The second commit is to support externalCatalog registration. So please
focus on the second commit when you review this pr.
The main changes in the second commit including:
1. add registerExternalCatalog method in TableEnvironment to register
external catalog
2. add scan method in TableEnvironment to scan the table of the external
catalog
3. add test cases for ExternalCatalog, including registration and scan
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/alibaba/flink flink-5570
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3409.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3409
----
commit d0e1ab20078adc4f788e9c2d2c167f0251ae3476
Author: jingzhang <[email protected]>
Date: 2017-02-22T11:28:08Z
Introduce interface for external catalog, and provide an in-memory
implementation for test or develop. Integrate with calcite catalog.
commit 05e2b13847fab01e330d4bf2232886a793f7dd0c
Author: jingzhang <[email protected]>
Date: 2017-02-24T06:10:50Z
Support register external catalog to table environment
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
