Page History

/**
 * The CREATE TABLE AS SELECT(CTAS) syntax requires CREATE/DROP TABLE operations via Catalog on the JM side,
 * so the specific Catalog implement should extends this interface, then the Catalog can be serialized as a part of {@link JobGraph}.
 */
@PublicEvolving
public interface SupportsAtomicCatalogAtomicCatalog extends Serializable {}

@PublicEvolving
public class TableConfigOptions {
    @Documentation.TableOption(execMode = Documentation.ExecMode.BATCH_STREAMING)
    public static final ConfigOption<Boolean> TABLE_CTAS_OR_RTAS_ATOMICITY_ENABLED =
            key("table.ctas-or-rtas.atomicity-enabled")
                    .booleanType()
                    .defaultValue(false)
                    .withDescription(
                            "Specifies if the create table as select or replace table as operation is executed atomically. "
                                  + "By default, the operation is non-atomic. The target table is created in Client side, and it will not be dropped even though the job fails or is cancelled. "
                                  + "If set this option to true, the target table is created in JM side, it also will be dropped when the job fails or is cancelled.");
}