Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.catalog.hive |
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 functionPath,
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)
Create a new table or view.
|
void |
GenericInMemoryCatalog.dropDatabase(String databaseName,
boolean ignoreIfNotExists) |
void |
Catalog.dropDatabase(String name,
boolean ignoreIfNotExists)
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) |
CatalogDatabase |
HiveCatalog.getDatabase(String databaseName) |
List<String> |
HiveCatalog.listFunctions(String databaseName) |
List<String> |
HiveCatalog.listTables(String databaseName) |
List<String> |
HiveCatalog.listViews(String databaseName) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.