flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From beyond1920 <...@git.apache.org>
Subject [GitHub] flink pull request #3406: [flink-5568] [Table API & SQL]Introduce interface ...
Date Fri, 24 Feb 2017 06:59:57 GMT
GitHub user beyond1920 opened a pull request:


    [flink-5568] [Table API & SQL]Introduce interface for catalog, and provide an in-memory
implementation. Integrate external catalog with calcite catalog

    This pr aims to introduce interface for catalog, and provide an in-memory implementation
for test and develop, finally integrate external catalog with calcite catalog.
    The main change including:
    1. Introduce ExternalCatalog abstraction, including introduce ExternalCatalogDatabase
as database   in catalog and ExternalCatalogTable as table in catalog.
    2. Provide an in-memory implementation for test and develop.
    3. Introduce ExternalCatalogSchema which is an implementation of Calcite Schema interface.
It registers database in ExternalCatalog as calcite Schemas, and tables in a database as Calcite
    4. Add ExternalCatalogCompatible annotation. The TableSource with this annotation represents
it could be converted to or from externalCatalogTable. ExternalCatalogTableConverter is the
converter between externalCatalogTable and tableSource.
    5. Introduce CatalogTableHelper utility. It has two responsibilities: * automatically
find the TableSources which are with ExternalCatalogCompatible annotation. * convert an ExternalCatalogTable
instance to a TableSourceTable instance.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/alibaba/flink dev

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #3406
commit d0e1ab20078adc4f788e9c2d2c167f0251ae3476
Author: jingzhang <beyond1920@126.com>
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.


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 infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message