...

CREATE TABLE ctas_hudi
 (
 	id BIGINT,
 	name STRING,
 	age INT
 )
 WITH ('connector.type' = 'hudi');

INSERT INTO ctas_hudi SELECT id, name, age FROM hive_catalog.default.test WHERE mod(id, 10) = 0;

Implementation Plan

Supported Job Mode

Support both streaming and batch mode.

...

we finally need to perform the operations of moving data and creating tables in JM.

Support in Table API

Support of that feature in Table API will require a separate FLIP, as the connect API requires a rework anyway.

...

changes will be verified by UT

Rejected Alternatives

N/A

References

1. Support SELECT clause in CREATE TABLE(CTAS)
2. MySQL CTAS syntax
3. Microsoft Azure Synapse CTAS
4. LanguageManual DDL#Create/Drop/ReloadFunction
5. Spark Create Table Syntax