Does Flink support such a feature currently?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Does Flink support such a feature currently?

RocMarshal
Hi, everyone!
           
       When using flink sql DDL to create a mysql mapping table, does flink support the automatic rendering of the target table schema if we put no column-names in `create table table_name_mapping2mysql () with (...)`? If this feature is not supported, is it necessary to consider improving it?
       
Thank you.
Best, Roc.
Reply | Threaded
Open this post in threaded view
|

Re: Does Flink support such a feature currently?

Marta Paes Moreira
Hi, Roc.

*Note:* in the future, please send this type of questions to the user
mailing list instead ([hidden email])!

If I understand your question correctly, this is possible using the LIKE
clause and a registered catalog. There is currently no implementation for
the MySQL JDBC catalog, but this is in the roadmap [1,2].

Once you register a catalog, you could do:

CREATE TABLE mapping_table

WITH (

  ...

 )

LIKE full_path_to_source_table;
Again, as of Flink 1.11 this only works for Postgres, not yet MySQL. I'm
copying in Bowen as he might be able to give more information on the
roadmap.

Marta

[1] https://issues.apache.org/jira/browse/FLINK-15352
[2]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-93%3A+JDBC+catalog+and+Postgres+catalog

On Tue, Sep 22, 2020 at 9:44 AM Roc Marshal <[hidden email]> wrote:

> Hi, everyone!
>
>        When using flink sql DDL to create a mysql mapping table, does
> flink support the automatic rendering of the target table schema if we put
> no column-names in `create table table_name_mapping2mysql () with (...)`?
> If this feature is not supported, is it necessary to consider improving it?
>
> Thank you.
> Best, Roc.