Bowen Li created FLINK-13313:
--------------------------------
Summary: create CatalogTableBuilder to support building CatalogTable from descriptors
Key: FLINK-13313
URL:
https://issues.apache.org/jira/browse/FLINK-13313 Project: Flink
Issue Type: Sub-task
Components: Table SQL / API
Affects Versions: 1.9.0, 1.10.0
Reporter: Bowen Li
Assignee: Bowen Li
Fix For: 1.9.0, 1.10.0
Previously, users can create an ExternalCatalogTable (deprecated) from descriptors via ExternalCatalogTableBuilder, and this helps smooth user experience of Flink Table API. E.g.
{code:java}
* ExternalCatalogTableBuilder(
* new ExternalSystemXYZ()
* .version("0.11"))
* .withFormat(
* new Json()
* .jsonSchema("{...}")
* .failOnMissingField(false))
* .withSchema(
* new Schema()
* .field("user-name", "VARCHAR").from("u_name")
* .field("count", "DECIMAL")
* .supportsStreaming()
* .asTableSource()
{code}
We need a similar new class {{CatalogTableBuilder}} for new Catalog APIs
cc [~tzulitai] [~ykt836]
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)