Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Implemented
    • Affects Version/s: None
    • Fix Version/s: 1.3.0
    • Component/s: Table API & SQL
    • Labels:
      None

      Description

      This issue aims to support register one or more ExternalCatalog (which is referred in https://issues.apache.org/jira/browse/FLINK-5568) to TableEnvironment. After registration, SQL and TableAPI queries could access to tables in the external catalogs without register those tables one by one to TableEnvironment beforehand.

      We plan to add two APIs in TableEnvironment:
      1. register externalCatalog

      def registerExternalCatalog(name: String, externalCatalog: ExternalCatalog): Unit
      

      2. scan a table from registered catalog and returns the resulting Table, the API is very useful in TableAPI queries.

      def scan(catalogName: String, tableIdentifier: TableIdentifier): Table
      

        Attachments

          Activity

            People

            • Assignee:
              jinyu.zj jingzhang
              Reporter:
              ykt836 Kurt Young
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: