[FLINK-28462] Table API support CREATE TABLE AS SELECT(CTAS)

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Assignee: tartarus
• Reporter: tartarus
• Created: 08/Jul/22 08:42
• Updated: 22/Jul/22 02:38

Description

TablePipeline tablePipeline = table.saveAs("my_ctas_table")
        .option("connector", "filesystem")
        .option("format", "testcsv")
        .option("path", "/tmp/my_ctas_table/")
        .create(true);
tablePipeline.execute(); 

Users can use CTAS with Table API