...
Public API Changes
Table Environment
Providing method that are used to execute CTAS for Table API user.
@PublicEvolving
public interface TableEnvironment { /**
* Registers the given {@link Table}'s result as a catalog table with {@link TableDescriptor}'s options.
*
* <p> CTAS for Table API.
*
* <p>Examples:
*
* <pre>{@code
* tEnv.createTable("MyTable", TableDescriptor.forConnector("hive")
* .build());
* }</pre>
*
* @param path The path under which the table will be registered. See also the {@link
* TableEnvironment} class description for the format of the path.
* @param descriptor Template for creating a {@link CatalogTable} instance.
* @param query The {@link Table} object describing the pipeline for further transformations.
*/
void createTable(String path, TableDescriptor descriptor, Table query);
} |
...
Providing method that are used to execute create table for CTAS to check table's options.
@PublicEvolving
public interface Catalog { /**
* Creates a new table for CTAS.
*
* <p>The framework will make sure to call this method with fully validated {@link
* CatalogTable} Those instances are easy to serialize for a durable catalog implementation.
*
* @param tablePath path of the table to be created
* @param table the table definition
* @param dropIfExists flag to specify behavior when a table already exists at the
* * given path: if set to false, it throws a TableAlreadyExistException, if set to true,
* * drop the table first, then create.
* @param checkTableOptions flag to specify behavior to check {@param table}'s options.
* @throws TableAlreadyExistException if table already exists and ignoreIfExists is false
* @throws DatabaseNotExistException if the database in tablePath doesn't exist
* @throws CatalogException in case of any runtime exception
*/
void createTable(ObjectPath tablePath, CatalogTable table, boolean dropIfExists,
boolean checkTableOptions)
throws TableAlreadyExistException, DatabaseNotExistException, CatalogException;
} |
Compatibility, Deprecation, and Migration Plan
...