@PublicEvolving public interface StagedTable extends Serializable
StagedTable
is designed to implement Flink's atomic semantic for CTAS(CREATE TABLE AS
SELECT) and RTAS([CREATE OR] REPLACE TABLE AS SELECT) statement using a two-phase commit
protocol. The StagedTable
is supposed to be returned via method SupportsStaging.applyStaging(org.apache.flink.table.connector.sink.abilities.SupportsStaging.StagingContext)
by the DynamicTableSink
which implements the SupportsStaging
interface.
When the Flink job for writing to a DynamicTableSink
with atomic semantic supporting
is CREATED, the begin()
will be called; when the Flink job is FINISHED, the
commit()
will be called; when the Flink job is FAILED or CANCELED, the abort()
will be called;
See more in SupportsStaging
.
Modifier and Type | Method and Description |
---|---|
void |
abort()
This method will be called when the job is failed or is canceled.
|
void |
begin()
This method will be called when the job is started.
|
void |
commit()
This method will be called when the job succeeds.
|
void begin()
void commit()
void abort()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.