Package org.apache.flink.table.execution
-
Class Summary Class Description StagingSinkJobStatusHook This hook is used to implement atomic semantics for CTAS(CREATE TABLE AS SELECT) or RTAS([CREATE OR] REPLACE TABLE AS SELECT) statement.
| Class | Description |
|---|---|
| StagingSinkJobStatusHook |
This hook is used to implement atomic semantics for CTAS(CREATE TABLE AS SELECT) or RTAS([CREATE
OR] REPLACE TABLE AS SELECT) statement.
|