@PublicEvolving public interface SupportsTruncate
DynamicTableSink
table using TRUNCATE
TABLE
statement.
For TRUNCATE TABLE
statement, if the corresponding DynamicTableSink
have
implemented this interface, then the method executeTruncation()
will be invoked in
execution phase. Otherwise, Flink will throw exception directly.
Modifier and Type | Method and Description |
---|---|
void |
executeTruncation()
Execute truncating table.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.