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)