public class FlinkCatalog
extends org.apache.flink.table.catalog.AbstractCatalog
| Modifier and Type | Field and Description |
|---|---|
static String |
LAST_UPDATE_TIME_KEY |
static String |
NUM_FILES_KEY |
static String |
NUM_ROWS_KEY |
static String |
TOTAL_SIZE_KEY |
| Constructor and Description |
|---|
FlinkCatalog(Catalog catalog,
String name,
String defaultDatabase,
ClassLoader classLoader,
Options options) |
| 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 |
alterTable(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogBaseTable newTable,
List<org.apache.flink.table.catalog.TableChange> tableChanges,
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) |
protected Schema |
buildPaimonSchema(Identifier identifier,
org.apache.flink.table.catalog.CatalogTable catalogTable,
Map<String,String> options) |
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) |
static Schema |
fromCatalogTable(org.apache.flink.table.catalog.CatalogTable table) |
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.procedures.Procedure |
getProcedure(org.apache.flink.table.catalog.ObjectPath procedurePath)
Do not annotate with
@override here to maintain compatibility with Flink 1.17-. |
org.apache.flink.table.catalog.CatalogTable |
getTable(org.apache.flink.table.catalog.ObjectPath tablePath) |
org.apache.flink.table.catalog.CatalogTable |
getTable(org.apache.flink.table.catalog.ObjectPath tablePath,
long timestamp)
Do not annotate with
@override here to maintain compatibility with Flink 1.17-. |
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> |
listProcedures(String dbName)
Do not annotate with
@override here to maintain compatibility with Flink 1.17-. |
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) |
static Identifier |
toIdentifier(org.apache.flink.table.catalog.ObjectPath path) |
getDefaultDatabase, getNamepublic static final String NUM_ROWS_KEY
public static final String LAST_UPDATE_TIME_KEY
public static final String TOTAL_SIZE_KEY
public static final String NUM_FILES_KEY
public FlinkCatalog(Catalog catalog, String name, String defaultDatabase, ClassLoader classLoader, Options options)
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.CatalogExceptionpublic boolean databaseExists(String databaseName) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.CatalogExceptionorg.apache.flink.table.catalog.exceptions.DatabaseNotExistExceptionpublic 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.DatabaseAlreadyExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.DatabaseNotEmptyExceptionorg.apache.flink.table.catalog.exceptions.DatabaseNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.DatabaseNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.TableNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic org.apache.flink.table.catalog.CatalogTable getTable(org.apache.flink.table.catalog.ObjectPath tablePath,
long timestamp)
throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
org.apache.flink.table.catalog.exceptions.CatalogException
@override here to maintain compatibility with Flink 1.17-.org.apache.flink.table.catalog.exceptions.TableNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic boolean tableExists(org.apache.flink.table.catalog.ObjectPath tablePath)
throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.TableNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.TableAlreadyExistExceptionorg.apache.flink.table.catalog.exceptions.DatabaseNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionprotected Schema buildPaimonSchema(Identifier identifier, org.apache.flink.table.catalog.CatalogTable catalogTable, Map<String,String> options)
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.TableNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic void alterTable(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogBaseTable newTable,
List<org.apache.flink.table.catalog.TableChange> tableChanges,
boolean ignoreIfNotExists)
throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic final void open()
throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogExceptionpublic final void close()
throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogExceptionpublic static Schema fromCatalogTable(org.apache.flink.table.catalog.CatalogTable table)
public static Identifier toIdentifier(org.apache.flink.table.catalog.ObjectPath path)
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.CatalogExceptionpublic 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.CatalogExceptionorg.apache.flink.table.catalog.exceptions.TableNotExistExceptionorg.apache.flink.table.catalog.exceptions.TableAlreadyExistExceptionpublic final List<String> listViews(String databaseName) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogExceptionpublic final List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.TableNotPartitionedException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistExceptionorg.apache.flink.table.catalog.exceptions.TableNotPartitionedExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.TableNotExistException, org.apache.flink.table.catalog.exceptions.TableNotPartitionedException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistExceptionorg.apache.flink.table.catalog.exceptions.TableNotPartitionedExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.CatalogExceptionpublic 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.PartitionNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.PartitionNotExistException,
org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.CatalogExceptionpublic final List<String> listFunctions(String dbName) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.FunctionNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic final boolean functionExists(org.apache.flink.table.catalog.ObjectPath functionPath)
throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic 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.CatalogExceptionpublic List<String> listProcedures(String dbName) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
@override here to maintain compatibility with Flink 1.17-.org.apache.flink.table.catalog.exceptions.DatabaseNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionpublic org.apache.flink.table.procedures.Procedure getProcedure(org.apache.flink.table.catalog.ObjectPath procedurePath)
throws org.apache.flink.table.catalog.exceptions.ProcedureNotExistException,
org.apache.flink.table.catalog.exceptions.CatalogException
@override here to maintain compatibility with Flink 1.17-.org.apache.flink.table.catalog.exceptions.ProcedureNotExistExceptionorg.apache.flink.table.catalog.exceptions.CatalogExceptionCopyright © 2023–2024 The Apache Software Foundation. All rights reserved.