[FLINK-5570] Support register external catalog to table environment

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.3.0
• Component/s: Table SQL / API
• Assignee: Jing Zhang
• Reporter: Kurt Young
• Created: 19/Jan/17 03:18
• Updated: 27/Jan/22 17:43
• Resolved: 24/Mar/17 19:40

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