You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/07/17 22:21:00 UTC

[jira] [Created] (FLINK-13313) create CatalogTableBuilder to support building CatalogTable from descriptors

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)