Package | Description |
---|---|
org.apache.flink.connector.jdbc.catalog | |
org.apache.flink.table.catalog | |
org.apache.flink.table.catalog.hive |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJdbcCatalog.alterDatabase(String name,
CatalogDatabase newDatabase,
boolean ignoreIfNotExists) |
void |
AbstractJdbcCatalog.createFunction(ObjectPath functionPath,
CatalogFunction function,
boolean ignoreIfExists) |
void |
AbstractJdbcCatalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists) |
void |
AbstractJdbcCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
CatalogDatabase |
JdbcCatalog.getDatabase(String databaseName) |
CatalogDatabase |
AbstractJdbcCatalog.getDatabase(String databaseName) |
List<String> |
AbstractJdbcCatalog.listFunctions(String dbName) |
List<String> |
JdbcCatalog.listTables(String databaseName) |
List<String> |
MySqlCatalog.listTables(String databaseName) |
List<String> |
PostgresCatalog.listTables(String databaseName) |
List<String> |
AbstractJdbcCatalog.listViews(String databaseName) |
Modifier and Type | Method and Description |
---|---|
void |
GenericInMemoryCatalog.alterDatabase(String databaseName,
CatalogDatabase newDatabase,
boolean ignoreIfNotExists) |
void |
Catalog.alterDatabase(String name,
CatalogDatabase newDatabase,
boolean ignoreIfNotExists)
Modify an existing database.
|
void |
GenericInMemoryCatalog.createFunction(ObjectPath path,
CatalogFunction function,
boolean ignoreIfExists) |
void |
Catalog.createFunction(ObjectPath functionPath,
CatalogFunction function,
boolean ignoreIfExists)
Create a function.
|
void |
GenericInMemoryCatalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists) |
void |
Catalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists)
Creates a new table or view.
|
default void |
Catalog.dropDatabase(String name,
boolean ignoreIfNotExists)
Drop a database.
|
void |
GenericInMemoryCatalog.dropDatabase(String databaseName,
boolean ignoreIfNotExists,
boolean cascade) |
void |
Catalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade)
Drop a database.
|
CatalogDatabase |
GenericInMemoryCatalog.getDatabase(String databaseName) |
CatalogDatabase |
Catalog.getDatabase(String databaseName)
Get a database from this catalog.
|
List<String> |
GenericInMemoryCatalog.listFunctions(String databaseName) |
List<String> |
Catalog.listFunctions(String dbName)
List the names of all functions in the given database.
|
List<String> |
GenericInMemoryCatalog.listTables(String databaseName) |
List<String> |
Catalog.listTables(String databaseName)
Get names of all tables and views under this database.
|
List<String> |
GenericInMemoryCatalog.listViews(String databaseName) |
List<String> |
Catalog.listViews(String databaseName)
Get names of all views under this database.
|
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.alterDatabase(String databaseName,
CatalogDatabase newDatabase,
boolean ignoreIfNotExists) |
void |
HiveCatalog.createFunction(ObjectPath functionPath,
CatalogFunction function,
boolean ignoreIfExists) |
void |
HiveCatalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists) |
void |
HiveCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
CatalogDatabase |
HiveCatalog.getDatabase(String databaseName) |
org.apache.hadoop.hive.metastore.api.Database |
HiveCatalog.getHiveDatabase(String databaseName) |
List<String> |
HiveCatalog.listFunctions(String databaseName) |
List<String> |
HiveCatalog.listTables(String databaseName) |
List<String> |
HiveCatalog.listViews(String databaseName) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.