Package | Description |
---|---|
org.apache.flink.table.store.file.catalog | |
org.apache.flink.table.store.hive |
Modifier and Type | Method and Description |
---|---|
void |
FileSystemCatalog.createTable(org.apache.flink.table.catalog.ObjectPath tablePath,
UpdateSchema table,
boolean ignoreIfExists) |
void |
Catalog.createTable(org.apache.flink.table.catalog.ObjectPath tablePath,
UpdateSchema tableSchema,
boolean ignoreIfExists)
Create a new table.
|
void |
FileSystemCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
void |
Catalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade)
Drop a database.
|
List<String> |
FileSystemCatalog.listTables(String databaseName) |
List<String> |
Catalog.listTables(String databaseName)
Get names of all tables under this database.
|
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.createTable(org.apache.flink.table.catalog.ObjectPath tablePath,
UpdateSchema updateSchema,
boolean ignoreIfExists) |
void |
HiveCatalog.dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
List<String> |
HiveCatalog.listTables(String databaseName) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.