Package | Description |
---|---|
org.apache.flink.table.store.file.catalog | |
org.apache.flink.table.store.file.schema | |
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.
|
Modifier and Type | Method and Description |
---|---|
static UpdateSchema |
UpdateSchema.fromCatalogTable(org.apache.flink.table.catalog.CatalogTable catalogTable) |
UpdateSchema |
TableSchema.toUpdateSchema() |
Modifier and Type | Method and Description |
---|---|
TableSchema |
SchemaManager.commitNewVersion(UpdateSchema updateSchema)
Create a new schema from
UpdateSchema . |
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.createTable(org.apache.flink.table.catalog.ObjectPath tablePath,
UpdateSchema updateSchema,
boolean ignoreIfExists) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.