Page History

/** A table that need to be created for CTAS. */
@PublicEvolving
public interface CreateOrReplaceTable {
 * A table to help the Table API implement the Create Table As Select(CTAS) feature.
 * The Create or Replace Table and Replace Table feature may be supported in the future,
 * so it is named CreateOrReplaceTable.
 */
@PublicEvolving
public interface CreateOrReplaceTable {

    /**
     * Adding table options to CreateOrReplaceTable.
     *
     * <p>Example:
     *
     * <pre>{@code
     * tab.option("connector", "filesystem");
     * }</pre>
     */
    CreateOrReplaceTable option(String key, String value);

    /**
     * Create the table in the specified path and write the pipeline data to this table.
     *
     * <p>Example:
     *
     * <pre>{@code
     * table.saveAs("my_ctas_table")
     *         .option("connector", "filesystem")
     *         .option("format", "testcsv")
     *         .option("path", "/tmp/my_ctas_table/")
     *         .create();
     * }</pre>
     */
    TablePipeline create();

    /**
     * Create addthe table option.
     * such as option("connector", "filesystem"); under the specified path if not exist and write the pipeline data to this table.
     */
    CreateOrRepalceTable option(String key, String value)  * <p>Example:
;     *
     * <pre>{@code/**
     * Create the table under the specified path
table.saveAs("my_ctas_table")
     *      * and write the pipeline data to this table.
  .option("connector", "filesystem")
     *    */
    TablePipeline; create().option("format", "testcsv")
    / **
       * Create the table under the specified path if not exist
 .option("path", "/tmp/my_ctas_table/")
     *       * and write the pipeline data to this table. .createIfNotExist();
     * }</pre>
     */
    TablePipeline createIfNotExist();
}

@PublicEvolving
public interface Catalog {

   /**
    * When the Create Table As Select(CTAS) functionfeature was used, the Catalog combined {@link Catalog#supportsManagedTable}
    * to infer whether to add some options to the {@link CatalogBaseTable}.
    *
    * For example:
    * {@link JdbcCatalog} can add connector = 'jdbc', user, password, url and other options to {@link CatalogBaseTable},
    * {@link HiveCatalog} can add connector = 'hive' to {@link CatalogBaseTable}, help generate TableSink.
    * The tables in {@link GenericInMemoryCatalog} already exist externally, 
    * options must be filled in manually by the user, and the Catalog cannot be automatically inferred.
    */
    default CatalogBaseTable inferTableOptions(ObjectPath tablePath, CatalogBaseTable table) {
        throw new UnsupportedOperationException();
    }
}