Modifier and Type | Method and Description |
---|---|
void |
DelegateCatalog.createTable(Identifier identifier,
Schema schema,
boolean ignoreIfExists) |
void |
Catalog.createTable(Identifier identifier,
Schema schema,
boolean ignoreIfExists)
Create a new table.
|
void |
AbstractCatalog.createTable(Identifier identifier,
Schema schema,
boolean ignoreIfExists) |
void |
DelegateCatalog.createView(Identifier identifier,
View view,
boolean ignoreIfExists) |
default void |
Catalog.createView(Identifier identifier,
View view,
boolean ignoreIfExists)
Create a new view.
|
void |
DelegateCatalog.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 |
CachingCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
Database |
DelegateCatalog.getDatabase(String name) |
Database |
Catalog.getDatabase(String name)
Return a
Database identified by the given name. |
Database |
AbstractCatalog.getDatabase(String name) |
Database |
CachingCatalog.getDatabase(String databaseName) |
Database |
FileSystemCatalog.getDatabaseImpl(String name) |
protected abstract Database |
AbstractCatalog.getDatabaseImpl(String name) |
List<String> |
DelegateCatalog.listTables(String databaseName) |
List<String> |
Catalog.listTables(String databaseName)
Get names of all tables under this database.
|
List<String> |
AbstractCatalog.listTables(String databaseName) |
List<String> |
DelegateCatalog.listViews(String databaseName) |
default List<String> |
Catalog.listViews(String databaseName)
Get names of all views under this database.
|
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 |
---|---|
static long |
FlinkOrphanFilesClean.executeDatabaseOrphanFiles(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
Catalog catalog,
long olderThanMillis,
SerializableConsumer<Path> fileCleaner,
Integer parallelism,
String databaseName,
String tableName) |
Modifier and Type | Method and Description |
---|---|
String[] |
RepairProcedure.call(org.apache.flink.table.procedure.ProcedureContext procedureContext,
String identifier) |
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.createView(Identifier identifier,
View view,
boolean ignoreIfExists) |
Database |
HiveCatalog.getDatabaseImpl(String name) |
List<String> |
HiveCatalog.listViews(String databaseName) |
Modifier and Type | Method and Description |
---|---|
protected Database |
JdbcCatalog.getDatabaseImpl(String databaseName) |
Modifier and Type | Method and Description |
---|---|
static List<LocalOrphanFilesClean> |
LocalOrphanFilesClean.createOrphanFilesCleans(Catalog catalog,
String databaseName,
String tableName,
long olderThanMillis,
SerializableConsumer<Path> fileCleaner,
Integer parallelism) |
static long |
LocalOrphanFilesClean.executeDatabaseOrphanFiles(Catalog catalog,
String databaseName,
String tableName,
long olderThanMillis,
SerializableConsumer<Path> fileCleaner,
Integer parallelism) |
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.