...
Providing method that are used to execute CTAS(CREATE TABLE AS SELECT) for Table API user.
@PublicEvolving
public interface Table extends Explainable<Table>, Executable {
/**
* Declare the pipeline defined by the given {@link Table} object
* to create the table at the specified path.
*/
CreateOrRepalceTable saveAs(String tablePath);
} |
...
Proposing a public interface CreateOrReplaceTable used by CTAS(CREATE TABLE AS SELECT) for table API.
/** A table that need to be created for CTAS. */
@PublicEvolving
public interface CreateOrReplaceTable {
/**
* add table option.
* such as option("connector", "filesystem");
*/
CreateOrRepalceTable option(String key, String value);
/**
* Create the table under the specified path
* and write the pipeline data to this table.
*/
TablePipeline create();
/**
* Create the table under the specified path if not exist
* and write the pipeline data to this table.
*/
TablePipeline createIfNotExist();
} |
...