public class FlinkCatalog
extends org.apache.flink.table.catalog.AbstractCatalog
Constructor and Description |
---|
FlinkCatalog(Catalog catalog,
String name,
String defaultDatabase) |
Modifier and Type | Method and Description |
---|---|
void |
alterDatabase(String name,
org.apache.flink.table.catalog.CatalogDatabase newDatabase,
boolean ignoreIfNotExists) |
void |
alterFunction(org.apache.flink.table.catalog.ObjectPath functionPath,
org.apache.flink.table.catalog.CatalogFunction newFunction,
boolean ignoreIfNotExists) |
void |
alterPartition(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
org.apache.flink.table.catalog.CatalogPartition newPartition,
boolean ignoreIfNotExists) |
void |
alterPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists) |
void |
alterPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
org.apache.flink.table.catalog.stats.CatalogTableStatistics partitionStatistics,
boolean ignoreIfNotExists) |
void |
alterTable(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogBaseTable newTable,
boolean ignoreIfNotExists) |
void |
alterTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists) |
void |
alterTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.stats.CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists) |
Catalog |
catalog() |
void |
close() |
void |
createDatabase(String name,
org.apache.flink.table.catalog.CatalogDatabase database,
boolean ignoreIfExists) |
void |
createFunction(org.apache.flink.table.catalog.ObjectPath functionPath,
org.apache.flink.table.catalog.CatalogFunction function,
boolean ignoreIfExists) |
void |
createPartition(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
org.apache.flink.table.catalog.CatalogPartition partition,
boolean ignoreIfExists) |
void |
createTable(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogBaseTable table,
boolean ignoreIfExists) |
boolean |
databaseExists(String databaseName) |
void |
dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
void |
dropFunction(org.apache.flink.table.catalog.ObjectPath functionPath,
boolean ignoreIfNotExists) |
void |
dropPartition(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
boolean ignoreIfNotExists) |
void |
dropTable(org.apache.flink.table.catalog.ObjectPath tablePath,
boolean ignoreIfNotExists) |
boolean |
functionExists(org.apache.flink.table.catalog.ObjectPath functionPath) |
org.apache.flink.table.catalog.CatalogDatabase |
getDatabase(String databaseName) |
Optional<org.apache.flink.table.factories.Factory> |
getFactory() |
org.apache.flink.table.catalog.CatalogFunction |
getFunction(org.apache.flink.table.catalog.ObjectPath functionPath) |
org.apache.flink.table.catalog.CatalogPartition |
getPartition(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
org.apache.flink.table.catalog.stats.CatalogColumnStatistics |
getPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
org.apache.flink.table.catalog.stats.CatalogTableStatistics |
getPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
org.apache.flink.table.catalog.CatalogTable |
getTable(org.apache.flink.table.catalog.ObjectPath tablePath) |
org.apache.flink.table.catalog.stats.CatalogColumnStatistics |
getTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath) |
org.apache.flink.table.catalog.stats.CatalogTableStatistics |
getTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath) |
List<String> |
listDatabases() |
List<String> |
listFunctions(String dbName) |
List<org.apache.flink.table.catalog.CatalogPartitionSpec> |
listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath) |
List<org.apache.flink.table.catalog.CatalogPartitionSpec> |
listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
List<org.apache.flink.table.catalog.CatalogPartitionSpec> |
listPartitionsByFilter(org.apache.flink.table.catalog.ObjectPath tablePath,
List<org.apache.flink.table.expressions.Expression> filters) |
List<String> |
listTables(String databaseName) |
List<String> |
listViews(String databaseName) |
void |
open() |
boolean |
partitionExists(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
void |
renameTable(org.apache.flink.table.catalog.ObjectPath tablePath,
String newTableName,
boolean ignoreIfNotExists) |
boolean |
tableExists(org.apache.flink.table.catalog.ObjectPath tablePath) |
getDefaultDatabase, getName
@VisibleForTesting public Catalog catalog()
public Optional<org.apache.flink.table.factories.Factory> getFactory()
public List<String> listDatabases() throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public boolean databaseExists(String databaseName) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.CatalogDatabase getDatabase(String databaseName) throws org.apache.flink.table.catalog.exceptions.CatalogException, org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
public void createDatabase(String name, org.apache.flink.table.catalog.CatalogDatabase database, boolean ignoreIfExists) throws org.apache.flink.table.catalog.exceptions.DatabaseAlreadyExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseAlreadyExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void dropDatabase(String name, boolean ignoreIfNotExists, boolean cascade) throws org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException, org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<String> listTables(String databaseName) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.CatalogTable getTable(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public boolean tableExists(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public void dropTable(org.apache.flink.table.catalog.ObjectPath tablePath, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void createTable(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogBaseTable table, boolean ignoreIfExists) throws org.apache.flink.table.catalog.exceptions.TableAlreadyExistException, org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableAlreadyExistException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterTable(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogBaseTable newTable, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void open() throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void close() throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void alterDatabase(String name, org.apache.flink.table.catalog.CatalogDatabase newDatabase, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void renameTable(org.apache.flink.table.catalog.ObjectPath tablePath, String newTableName, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException, org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.TableAlreadyExistException
org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.TableAlreadyExistException
public final List<String> listViews(String databaseName) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitionsByFilter(org.apache.flink.table.catalog.ObjectPath tablePath, List<org.apache.flink.table.expressions.Expression> filters) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final org.apache.flink.table.catalog.CatalogPartition getPartition(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public final boolean partitionExists(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void createPartition(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, org.apache.flink.table.catalog.CatalogPartition partition, boolean ignoreIfExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void dropPartition(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void alterPartition(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, org.apache.flink.table.catalog.CatalogPartition newPartition, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final List<String> listFunctions(String dbName) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final org.apache.flink.table.catalog.CatalogFunction getFunction(org.apache.flink.table.catalog.ObjectPath functionPath) throws org.apache.flink.table.catalog.exceptions.FunctionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.FunctionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public final boolean functionExists(org.apache.flink.table.catalog.ObjectPath functionPath) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void createFunction(org.apache.flink.table.catalog.ObjectPath functionPath, org.apache.flink.table.catalog.CatalogFunction function, boolean ignoreIfExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void alterFunction(org.apache.flink.table.catalog.ObjectPath functionPath, org.apache.flink.table.catalog.CatalogFunction newFunction, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void dropFunction(org.apache.flink.table.catalog.ObjectPath functionPath, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final org.apache.flink.table.catalog.stats.CatalogTableStatistics getTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final org.apache.flink.table.catalog.stats.CatalogColumnStatistics getTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final org.apache.flink.table.catalog.stats.CatalogTableStatistics getPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final org.apache.flink.table.catalog.stats.CatalogColumnStatistics getPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void alterTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.stats.CatalogTableStatistics tableStatistics, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void alterTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void alterPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, org.apache.flink.table.catalog.stats.CatalogTableStatistics partitionStatistics, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public final void alterPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.