@PublicEvolving public interface Catalog
TemporaryOperationListener
interface.Modifier and Type | Method and Description |
---|---|
void |
alterDatabase(String name,
CatalogDatabase newDatabase,
boolean ignoreIfNotExists)
Modify an existing database.
|
void |
alterFunction(ObjectPath functionPath,
CatalogFunction newFunction,
boolean ignoreIfNotExists)
Modify an existing function.
|
void |
alterPartition(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogPartition newPartition,
boolean ignoreIfNotExists)
Alter a partition.
|
void |
alterPartitionColumnStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists)
Update the column statistics of a table partition.
|
void |
alterPartitionStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogTableStatistics partitionStatistics,
boolean ignoreIfNotExists)
Update the statistics of a table partition.
|
void |
alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists)
Modifies an existing table or view.
|
default void |
alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
List<TableChange> tableChanges,
boolean ignoreIfNotExists)
Modifies an existing table or view.
|
void |
alterTableColumnStatistics(ObjectPath tablePath,
CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists)
Update the column statistics of a table.
|
void |
alterTableStatistics(ObjectPath tablePath,
CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists)
Update the statistics of a table.
|
default List<CatalogColumnStatistics> |
bulkGetPartitionColumnStatistics(ObjectPath tablePath,
List<CatalogPartitionSpec> partitionSpecs)
Get a list of column statistics for given partitions.
|
default List<CatalogTableStatistics> |
bulkGetPartitionStatistics(ObjectPath tablePath,
List<CatalogPartitionSpec> partitionSpecs)
Get a list of statistics of given partitions.
|
void |
close()
Close the catalog when it is no longer needed and release any resource that it might be
holding.
|
void |
createDatabase(String name,
CatalogDatabase database,
boolean ignoreIfExists)
Create a database.
|
void |
createFunction(ObjectPath functionPath,
CatalogFunction function,
boolean ignoreIfExists)
Create a function.
|
void |
createPartition(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogPartition partition,
boolean ignoreIfExists)
Create a partition.
|
void |
createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists)
Creates a new table or view.
|
boolean |
databaseExists(String databaseName)
Check if a database exists in this catalog.
|
default void |
dropDatabase(String name,
boolean ignoreIfNotExists)
Drop a database.
|
void |
dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade)
Drop a database.
|
void |
dropFunction(ObjectPath functionPath,
boolean ignoreIfNotExists)
Drop a function.
|
void |
dropPartition(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
boolean ignoreIfNotExists)
Drop a partition.
|
void |
dropTable(ObjectPath tablePath,
boolean ignoreIfNotExists)
Drop a table or view.
|
boolean |
functionExists(ObjectPath functionPath)
Check whether a function exists or not.
|
CatalogDatabase |
getDatabase(String databaseName)
Get a database from this catalog.
|
String |
getDefaultDatabase()
Get the name of the default database for this catalog.
|
default Optional<Factory> |
getFactory()
Returns a factory for creating instances from catalog objects.
|
CatalogFunction |
getFunction(ObjectPath functionPath)
Get the function.
|
default Optional<FunctionDefinitionFactory> |
getFunctionDefinitionFactory()
Get an optional
FunctionDefinitionFactory instance that's responsible for
instantiating function definitions. |
CatalogPartition |
getPartition(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec)
Get a partition of the given table.
|
CatalogColumnStatistics |
getPartitionColumnStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec)
Get the column statistics of a partition.
|
CatalogTableStatistics |
getPartitionStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec)
Get the statistics of a partition.
|
default Procedure |
getProcedure(ObjectPath procedurePath)
Get the procedure.
|
CatalogBaseTable |
getTable(ObjectPath tablePath)
|
default CatalogBaseTable |
getTable(ObjectPath tablePath,
long timestamp)
|
CatalogColumnStatistics |
getTableColumnStatistics(ObjectPath tablePath)
Get the column statistics of a table.
|
default Optional<TableFactory> |
getTableFactory()
Deprecated.
Use
getFactory() for the new factory stack. The new factory stack uses
the new table sources and sinks defined in FLIP-95 and a slightly different discovery
mechanism. |
CatalogTableStatistics |
getTableStatistics(ObjectPath tablePath)
Get the statistics of a table.
|
List<String> |
listDatabases()
Get the names of all databases in this catalog.
|
List<String> |
listFunctions(String dbName)
List the names of all functions in the given database.
|
List<CatalogPartitionSpec> |
listPartitions(ObjectPath tablePath)
Get CatalogPartitionSpec of all partitions of the table.
|
List<CatalogPartitionSpec> |
listPartitions(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec)
Get CatalogPartitionSpec of all partitions that is under the given CatalogPartitionSpec in
the table.
|
List<CatalogPartitionSpec> |
listPartitionsByFilter(ObjectPath tablePath,
List<Expression> filters)
Get CatalogPartitionSpec of partitions by expression filters in the table.
|
default List<String> |
listProcedures(String dbName)
List the names of all procedures in the given database.
|
List<String> |
listTables(String databaseName)
Get names of all tables and views under this database.
|
List<String> |
listViews(String databaseName)
Get names of all views under this database.
|
void |
open()
Open the catalog.
|
boolean |
partitionExists(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec)
Check whether a partition exists or not.
|
void |
renameTable(ObjectPath tablePath,
String newTableName,
boolean ignoreIfNotExists)
Rename an existing table or view.
|
default boolean |
supportsManagedTable()
Deprecated.
This method will be removed soon. Please see FLIP-346 for more details.
|
boolean |
tableExists(ObjectPath tablePath)
Check if a table or view exists in this catalog.
|
default Optional<Factory> getFactory()
This method enables bypassing the discovery process. Implementers can directly pass
internal catalog-specific objects to their own factory. For example, a custom CatalogTable
can be processed by a custom DynamicTableFactory
.
Because all factories are interfaces, the returned Factory
instance can implement
multiple supported extension points. An instanceof
check is performed by the caller
that checks whether a required factory is implemented; otherwise the discovery process is
used.
@Deprecated default Optional<TableFactory> getTableFactory()
getFactory()
for the new factory stack. The new factory stack uses
the new table sources and sinks defined in FLIP-95 and a slightly different discovery
mechanism.TableFactory
instance that's responsible for generating table-related
instances stored in this catalog, instances such as source/sink.default Optional<FunctionDefinitionFactory> getFunctionDefinitionFactory()
FunctionDefinitionFactory
instance that's responsible for
instantiating function definitions.void open() throws CatalogException
CatalogException
- in case of any runtime exceptionvoid close() throws CatalogException
CatalogException
- in case of any runtime exception@Nullable String getDefaultDatabase() throws CatalogException
If the default database is null, users will need to set a current database themselves or qualify identifiers at least with the database name when using the catalog.
CatalogException
- in case of any runtime exceptionList<String> listDatabases() throws CatalogException
CatalogException
- in case of any runtime exceptionCatalogDatabase getDatabase(String databaseName) throws DatabaseNotExistException, CatalogException
databaseName
- Name of the databaseDatabaseNotExistException
- if the database does not existCatalogException
- in case of any runtime exceptionboolean databaseExists(String databaseName) throws CatalogException
databaseName
- Name of the databaseCatalogException
- in case of any runtime exceptionvoid createDatabase(String name, CatalogDatabase database, boolean ignoreIfExists) throws DatabaseAlreadyExistException, CatalogException
name
- Name of the database to be createddatabase
- The database definitionignoreIfExists
- Flag to specify behavior when a database with the given name already
exists: if set to false, throw a DatabaseAlreadyExistException, if set to true, do
nothing.DatabaseAlreadyExistException
- if the given database already exists and ignoreIfExists
is falseCatalogException
- in case of any runtime exceptiondefault void dropDatabase(String name, boolean ignoreIfNotExists) throws DatabaseNotExistException, DatabaseNotEmptyException, CatalogException
name
- Name of the database to be dropped.ignoreIfNotExists
- Flag to specify behavior when the database does not exist: if set to
false, throw an exception, if set to true, do nothing.DatabaseNotExistException
- if the given database does not existCatalogException
- in case of any runtime exceptionDatabaseNotEmptyException
void dropDatabase(String name, boolean ignoreIfNotExists, boolean cascade) throws DatabaseNotExistException, DatabaseNotEmptyException, CatalogException
name
- Name of the database to be dropped.ignoreIfNotExists
- Flag to specify behavior when the database does not exist: if set to
false, throw an exception, if set to true, do nothing.cascade
- Flag to specify behavior when the database contains table or function: if set
to true, delete all tables and functions in the database and then delete the database, if
set to false, throw an exception.DatabaseNotExistException
- if the given database does not existDatabaseNotEmptyException
- if the given database is not empty and isRestrict is trueCatalogException
- in case of any runtime exceptionvoid alterDatabase(String name, CatalogDatabase newDatabase, boolean ignoreIfNotExists) throws DatabaseNotExistException, CatalogException
name
- Name of the database to be modifiednewDatabase
- The new database definitionignoreIfNotExists
- Flag to specify behavior when the given database does not exist: if
set to false, throw an exception, if set to true, do nothing.DatabaseNotExistException
- if the given database does not existCatalogException
- in case of any runtime exceptionList<String> listTables(String databaseName) throws DatabaseNotExistException, CatalogException
DatabaseNotExistException
- if the database does not existCatalogException
- in case of any runtime exceptionList<String> listViews(String databaseName) throws DatabaseNotExistException, CatalogException
databaseName
- the name of the given databaseDatabaseNotExistException
- if the database does not existCatalogException
- in case of any runtime exceptionCatalogBaseTable getTable(ObjectPath tablePath) throws TableNotExistException, CatalogException
CatalogTable
or CatalogView
identified by the given ObjectPath
. The framework will resolve the metadata objects when necessary.tablePath
- Path of the table or viewTableNotExistException
- if the target does not existCatalogException
- in case of any runtime exceptiondefault CatalogBaseTable getTable(ObjectPath tablePath, long timestamp) throws TableNotExistException, CatalogException
CatalogTable
or CatalogView
at a specific time identified by the
given ObjectPath
. The framework will resolve the metadata objects when necessary.tablePath
- Path of the table or viewtimestamp
- Timestamp of the table snapshot, which is milliseconds since 1970-01-01
00:00:00 UTCTableNotExistException
- if the target does not existCatalogException
- in case of any runtime exceptionboolean tableExists(ObjectPath tablePath) throws CatalogException
tablePath
- Path of the table or viewCatalogException
- in case of any runtime exceptionvoid dropTable(ObjectPath tablePath, boolean ignoreIfNotExists) throws TableNotExistException, CatalogException
tablePath
- Path of the table or view to be droppedignoreIfNotExists
- Flag to specify behavior when the table or view does not exist: if
set to false, throw an exception, if set to true, do nothing.TableNotExistException
- if the table or view does not existCatalogException
- in case of any runtime exceptionvoid renameTable(ObjectPath tablePath, String newTableName, boolean ignoreIfNotExists) throws TableNotExistException, TableAlreadyExistException, CatalogException
tablePath
- Path of the table or view to be renamednewTableName
- the new name of the table or viewignoreIfNotExists
- Flag to specify behavior when the table or view does not exist: if
set to false, throw an exception, if set to true, do nothing.TableNotExistException
- if the table does not existCatalogException
- in case of any runtime exceptionTableAlreadyExistException
void createTable(ObjectPath tablePath, CatalogBaseTable table, boolean ignoreIfExists) throws TableAlreadyExistException, DatabaseNotExistException, CatalogException
The framework will make sure to call this method with fully validated ResolvedCatalogTable
or ResolvedCatalogView
. Those instances are easy to serialize
for a durable catalog implementation.
tablePath
- path of the table or view to be createdtable
- the table definitionignoreIfExists
- flag to specify behavior when a table or view already exists at the
given path: if set to false, it throws a TableAlreadyExistException, if set to true, do
nothing.TableAlreadyExistException
- if table already exists and ignoreIfExists is falseDatabaseNotExistException
- if the database in tablePath doesn't existCatalogException
- in case of any runtime exceptionvoid alterTable(ObjectPath tablePath, CatalogBaseTable newTable, boolean ignoreIfNotExists) throws TableNotExistException, CatalogException
CatalogBaseTable
must
be of the same kind. For example, this doesn't allow altering a regular table to partitioned
table, or altering a view to a table, and vice versa.
The framework will make sure to call this method with fully validated ResolvedCatalogTable
or ResolvedCatalogView
. Those instances are easy to serialize
for a durable catalog implementation.
tablePath
- path of the table or view to be modifiednewTable
- the new table definitionignoreIfNotExists
- flag to specify behavior when the table or view does not exist: if
set to false, throw an exception, if set to true, do nothing.TableNotExistException
- if the table does not existCatalogException
- in case of any runtime exceptiondefault void alterTable(ObjectPath tablePath, CatalogBaseTable newTable, List<TableChange> tableChanges, boolean ignoreIfNotExists) throws TableNotExistException, CatalogException
CatalogBaseTable
must
be of the same kind. For example, this doesn't allow altering a regular table to partitioned
table, or altering a view to a table, and vice versa.
The framework will make sure to call this method with fully validated ResolvedCatalogTable
or ResolvedCatalogView
. Those instances are easy to serialize
for a durable catalog implementation.
tablePath
- path of the table or view to be modifiednewTable
- the new table definitiontableChanges
- change to describe the modification between the newTable and the original
table.ignoreIfNotExists
- flag to specify behavior when the table or view does not exist: if
set to false, throw an exception, if set to true, do nothing.TableNotExistException
- if the table does not existCatalogException
- in case of any runtime exception@Deprecated default boolean supportsManagedTable()
List<CatalogPartitionSpec> listPartitions(ObjectPath tablePath) throws TableNotExistException, TableNotPartitionedException, CatalogException
tablePath
- path of the tableTableNotExistException
- thrown if the table does not exist in the catalogTableNotPartitionedException
- thrown if the table is not partitionedCatalogException
- in case of any runtime exceptionList<CatalogPartitionSpec> listPartitions(ObjectPath tablePath, CatalogPartitionSpec partitionSpec) throws TableNotExistException, TableNotPartitionedException, PartitionSpecInvalidException, CatalogException
tablePath
- path of the tablepartitionSpec
- the partition spec to listTableNotExistException
- thrown if the table does not exist in the catalogTableNotPartitionedException
- thrown if the table is not partitionedCatalogException
- in case of any runtime exceptionPartitionSpecInvalidException
List<CatalogPartitionSpec> listPartitionsByFilter(ObjectPath tablePath, List<Expression> filters) throws TableNotExistException, TableNotPartitionedException, CatalogException
NOTE: For FieldReferenceExpression, the field index is based on schema of this table instead of partition columns only.
The passed in predicates have been translated in conjunctive form.
If catalog does not support this interface at present, throw an UnsupportedOperationException
directly. If the catalog does not have a valid filter, throw
the UnsupportedOperationException
directly. Planner will fallback to get all
partitions and filter by itself.
tablePath
- path of the tablefilters
- filters to push down filter to catalogTableNotExistException
- thrown if the table does not exist in the catalogTableNotPartitionedException
- thrown if the table is not partitionedCatalogException
- in case of any runtime exceptionCatalogPartition getPartition(ObjectPath tablePath, CatalogPartitionSpec partitionSpec) throws PartitionNotExistException, CatalogException
tablePath
- path of the tablepartitionSpec
- partition spec of partition to getPartitionNotExistException
- thrown if the partition doesn't existCatalogException
- in case of any runtime exceptionboolean partitionExists(ObjectPath tablePath, CatalogPartitionSpec partitionSpec) throws CatalogException
tablePath
- path of the tablepartitionSpec
- partition spec of the partition to checkCatalogException
- in case of any runtime exceptionvoid createPartition(ObjectPath tablePath, CatalogPartitionSpec partitionSpec, CatalogPartition partition, boolean ignoreIfExists) throws TableNotExistException, TableNotPartitionedException, PartitionSpecInvalidException, PartitionAlreadyExistsException, CatalogException
tablePath
- path of the table.partitionSpec
- partition spec of the partitionpartition
- the partition to add.ignoreIfExists
- flag to specify behavior if a partition with the given name already
exists: if set to false, it throws a PartitionAlreadyExistsException, if set to true,
nothing happens.TableNotExistException
- thrown if the target table does not existTableNotPartitionedException
- thrown if the target table is not partitionedPartitionSpecInvalidException
- thrown if the given partition spec is invalidPartitionAlreadyExistsException
- thrown if the target partition already existsCatalogException
- in case of any runtime exceptionvoid dropPartition(ObjectPath tablePath, CatalogPartitionSpec partitionSpec, boolean ignoreIfNotExists) throws PartitionNotExistException, CatalogException
tablePath
- path of the table.partitionSpec
- partition spec of the partition to dropignoreIfNotExists
- flag to specify behavior if the partition does not exist: if set to
false, throw an exception, if set to true, nothing happens.PartitionNotExistException
- thrown if the target partition does not existCatalogException
- in case of any runtime exceptionvoid alterPartition(ObjectPath tablePath, CatalogPartitionSpec partitionSpec, CatalogPartition newPartition, boolean ignoreIfNotExists) throws PartitionNotExistException, CatalogException
tablePath
- path of the tablepartitionSpec
- partition spec of the partitionnewPartition
- new partition to replace the old oneignoreIfNotExists
- flag to specify behavior if the partition does not exist: if set to
false, throw an exception, if set to true, nothing happens.PartitionNotExistException
- thrown if the target partition does not existCatalogException
- in case of any runtime exceptionList<String> listFunctions(String dbName) throws DatabaseNotExistException, CatalogException
dbName
- name of the database.DatabaseNotExistException
- if the database does not existCatalogException
- in case of any runtime exceptiondefault List<String> listProcedures(String dbName) throws DatabaseNotExistException, CatalogException
dbName
- name of the database.DatabaseNotExistException
- if the database does not existCatalogException
- in case of any runtime exceptionCatalogFunction getFunction(ObjectPath functionPath) throws FunctionNotExistException, CatalogException
functionPath
- path of the functionFunctionNotExistException
- if the function does not exist in the catalogCatalogException
- in case of any runtime exceptiondefault Procedure getProcedure(ObjectPath procedurePath) throws ProcedureNotExistException, CatalogException
procedurePath
- path of the procedureProcedureNotExistException
- if the procedure does not exist in the catalogCatalogException
- in case of any runtime exceptionboolean functionExists(ObjectPath functionPath) throws CatalogException
functionPath
- path of the functionCatalogException
- in case of any runtime exceptionvoid createFunction(ObjectPath functionPath, CatalogFunction function, boolean ignoreIfExists) throws FunctionAlreadyExistException, DatabaseNotExistException, CatalogException
functionPath
- path of the functionfunction
- the function to be createdignoreIfExists
- flag to specify behavior if a function with the given name already
exists: if set to false, it throws a FunctionAlreadyExistException, if set to true,
nothing happens.FunctionAlreadyExistException
- if the function already existDatabaseNotExistException
- if the given database does not existCatalogException
- in case of any runtime exceptionvoid alterFunction(ObjectPath functionPath, CatalogFunction newFunction, boolean ignoreIfNotExists) throws FunctionNotExistException, CatalogException
functionPath
- path of the functionnewFunction
- the function to be modifiedignoreIfNotExists
- flag to specify behavior if the function does not exist: if set to
false, throw an exception if set to true, nothing happensFunctionNotExistException
- if the function does not existCatalogException
- in case of any runtime exceptionvoid dropFunction(ObjectPath functionPath, boolean ignoreIfNotExists) throws FunctionNotExistException, CatalogException
functionPath
- path of the function to be droppedignoreIfNotExists
- flag to specify behavior if the function does not exist: if set to
false, throw an exception if set to true, nothing happensFunctionNotExistException
- if the function does not existCatalogException
- in case of any runtime exceptionCatalogTableStatistics getTableStatistics(ObjectPath tablePath) throws TableNotExistException, CatalogException
tablePath
- path of the tableTableNotExistException
- if the table does not exist in the catalogCatalogException
- in case of any runtime exceptionCatalogColumnStatistics getTableColumnStatistics(ObjectPath tablePath) throws TableNotExistException, CatalogException
tablePath
- path of the tableTableNotExistException
- if the table does not exist in the catalogCatalogException
- in case of any runtime exceptionCatalogTableStatistics getPartitionStatistics(ObjectPath tablePath, CatalogPartitionSpec partitionSpec) throws PartitionNotExistException, CatalogException
tablePath
- path of the tablepartitionSpec
- partition spec of the partitionPartitionNotExistException
- if the partition does not existCatalogException
- in case of any runtime exceptiondefault List<CatalogTableStatistics> bulkGetPartitionStatistics(ObjectPath tablePath, List<CatalogPartitionSpec> partitionSpecs) throws PartitionNotExistException, CatalogException
tablePath
- path of the tablepartitionSpecs
- partition specs of partitions that will be used to filter out all other
unrelated statistics, i.e. the statistics fetch will be limited within the given
partitionsPartitionNotExistException
- if one partition does not existCatalogException
- in case of any runtime exceptionCatalogColumnStatistics getPartitionColumnStatistics(ObjectPath tablePath, CatalogPartitionSpec partitionSpec) throws PartitionNotExistException, CatalogException
tablePath
- path of the tablepartitionSpec
- partition spec of the partitionPartitionNotExistException
- if the partition does not existCatalogException
- in case of any runtime exceptiondefault List<CatalogColumnStatistics> bulkGetPartitionColumnStatistics(ObjectPath tablePath, List<CatalogPartitionSpec> partitionSpecs) throws PartitionNotExistException, CatalogException
tablePath
- path of the tablepartitionSpecs
- partition specs of partitions that will be used to filter out all other
unrelated statistics, i.e. the statistics fetch will be limited within the given
partitionsPartitionNotExistException
- if one partition does not existCatalogException
- in case of any runtime exceptionvoid alterTableStatistics(ObjectPath tablePath, CatalogTableStatistics tableStatistics, boolean ignoreIfNotExists) throws TableNotExistException, CatalogException
tablePath
- path of the tabletableStatistics
- new statistics to updateignoreIfNotExists
- flag to specify behavior if the table does not exist: if set to
false, throw an exception, if set to true, nothing happens.TableNotExistException
- if the table does not exist in the catalogCatalogException
- in case of any runtime exceptionvoid alterTableColumnStatistics(ObjectPath tablePath, CatalogColumnStatistics columnStatistics, boolean ignoreIfNotExists) throws TableNotExistException, CatalogException, TablePartitionedException
tablePath
- path of the tablecolumnStatistics
- new column statistics to updateignoreIfNotExists
- flag to specify behavior if the table does not exist: if set to
false, throw an exception, if set to true, nothing happens.TableNotExistException
- if the table does not exist in the catalogCatalogException
- in case of any runtime exceptionTablePartitionedException
void alterPartitionStatistics(ObjectPath tablePath, CatalogPartitionSpec partitionSpec, CatalogTableStatistics partitionStatistics, boolean ignoreIfNotExists) throws PartitionNotExistException, CatalogException
tablePath
- path of the tablepartitionSpec
- partition spec of the partitionpartitionStatistics
- new statistics to updateignoreIfNotExists
- flag to specify behavior if the partition does not exist: if set to
false, throw an exception, if set to true, nothing happens.PartitionNotExistException
- if the partition does not existCatalogException
- in case of any runtime exceptionvoid alterPartitionColumnStatistics(ObjectPath tablePath, CatalogPartitionSpec partitionSpec, CatalogColumnStatistics columnStatistics, boolean ignoreIfNotExists) throws PartitionNotExistException, CatalogException
tablePath
- path of the tablepartitionSpec
- partition spec of the partition @@param columnStatistics new column
statistics to updateignoreIfNotExists
- flag to specify behavior if the partition does not exist: if set to
false, throw an exception, if set to true, nothing happens.PartitionNotExistException
- if the partition does not existCatalogException
- in case of any runtime exceptionCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.