...

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

In FLIP-218, Flink support CREATE TABLE AS SELECT  statement which allows users to create new tables based on existing tables or query result. It's convenient for data analysts and data scientists to manage their data. However, Flink does not currently support the REPLACE TABLE AS SELECT  statment which enables users to replace an existing table with new data. With REPLACE TABLE AS SELECT , they won't need to drop the table firstly, and use CREATE TABLE AS SELECT  then. Only one single REPLACE TABLE AS SELCT  statement can meet their needs.

So, this FLIP is aimed to support REPLACE TABLE AS SELECT  statement in Flink.

Public Interfaces

Syntax

We propose add the following syntax for REPLACE TABLE AS SELECT  statement:

Public Interfaces Change

We propose the following public interface changes for REPLACE TABLE AS SELECT  statement:

...