Modifier and Type | Method and Description |
---|---|
void |
Catalog.createTable(Identifier identifier,
Schema schema,
boolean ignoreIfExists)
Create a new table.
|
void |
AbstractCatalog.createTable(Identifier identifier,
Schema schema,
boolean ignoreIfExists) |
void |
DelegateCatalog.createTable(Identifier identifier,
Schema schema,
boolean ignoreIfExists) |
void |
CachingCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
void |
Catalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade)
Drop a database.
|
void |
AbstractCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
void |
DelegateCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
List<String> |
Catalog.listTables(String databaseName)
Get names of all tables under this database.
|
List<String> |
AbstractCatalog.listTables(String databaseName) |
List<String> |
DelegateCatalog.listTables(String databaseName) |
Map<String,String> |
CachingCatalog.loadDatabaseProperties(String databaseName) |
Map<String,String> |
Catalog.loadDatabaseProperties(String name)
Load database properties.
|
Map<String,String> |
AbstractCatalog.loadDatabaseProperties(String name) |
Map<String,String> |
DelegateCatalog.loadDatabaseProperties(String name) |
Map<String,String> |
FileSystemCatalog.loadDatabasePropertiesImpl(String name) |
protected abstract Map<String,String> |
AbstractCatalog.loadDatabasePropertiesImpl(String name) |
Constructor and Description |
---|
RemoveOrphanFilesAction(String warehouse,
String databaseName,
String tableName,
Map<String,String> catalogConfig,
Map<String,String> dynamicOptions) |
Modifier and Type | Method and Description |
---|---|
MultiTableScanBase.ScanResult |
MultiTableScanBase.scanTable(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T> ctx) |
protected void |
MultiTableScanBase.updateTableMap() |
Modifier and Type | Method and Description |
---|---|
String[] |
RepairProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext,
String identifier) |
Modifier and Type | Method and Description |
---|---|
Map<String,String> |
HiveCatalog.loadDatabasePropertiesImpl(String name) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,String> |
JdbcCatalog.loadDatabasePropertiesImpl(String databaseName) |
Modifier and Type | Method and Description |
---|---|
static List<OrphanFilesClean> |
OrphanFilesClean.createOrphanFilesCleans(Catalog catalog,
Map<String,String> tableConfig,
String databaseName,
String tableName) |
Modifier and Type | Method and Description |
---|---|
void |
PrivilegedCatalog.createTable(Identifier identifier,
Schema schema,
boolean ignoreIfExists) |
void |
PrivilegedCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.