THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Syntax
We propose add the following syntax for TRUNCATE TABLE statement.
| Code Block | ||
|---|---|---|
| ||
TRUNCATE TABLE table_name |
It only supports trucate permanent or temporary table, if it's a view or temporary table, it should throw TableException with message Truncate a view /temporary table is not support .
Public interfaces Changes
We propose add a inerface for TRUNCATE TABLE statment. The connectors can implement this interface to custom their logic for truncating table.
| Code Block | ||
|---|---|---|
| ||
/**
* Enables to delete all existing data in a {@link DynamicTableSink} table using {@code TRUNCATE
* TABLE} statement.
*
* <p>For {@code TRUNCATE TABLE} statement, if the corresponding {@link DynamicTableSink} have
* implemented this interface, then the method {@link #truncateTable()} will be invoked in execution
* phase. Otherwise, Flink will throw exception directly.
*/
@PublicEvolving
public interface SupportsTruncate {
/**
* Execute truncating table.
*
* @return true if truncate the table successfully otherwise false
*/
boolean executeTruncation();
} |
...