Package | Description |
---|---|
org.apache.flink.table.api.internal | |
org.apache.flink.table.catalog | |
org.apache.flink.table.catalog.hive |
Modifier and Type | Method and Description |
---|---|
protected void |
TableEnvironmentImpl.registerTableInternal(String name,
CatalogBaseTable table) |
Modifier and Type | Interface and Description |
---|---|
interface |
CatalogTable
Represents a table in a catalog.
|
interface |
CatalogView
Represents a view in a catalog.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCatalogTable
An abstract catalog table.
|
class |
AbstractCatalogView
An abstract catalog view.
|
class |
CatalogTableImpl
A catalog table implementation.
|
class |
CatalogViewImpl
An implementation of catalog view.
|
class |
ConnectorCatalogTable<T1,T2>
|
class |
QueryOperationCatalogView
A view created from a
QueryOperation via operations on Table . |
Modifier and Type | Method and Description |
---|---|
CatalogBaseTable |
CatalogTableImpl.copy() |
CatalogBaseTable |
CatalogViewImpl.copy() |
CatalogBaseTable |
ConnectorCatalogTable.copy() |
CatalogBaseTable |
CatalogBaseTable.copy()
Get a deep copy of the CatalogBaseTable instance.
|
CatalogBaseTable |
GenericInMemoryCatalog.getTable(ObjectPath tablePath) |
CatalogBaseTable |
Catalog.getTable(ObjectPath tablePath)
Get a CatalogTable or CatalogView identified by tablePath.
|
Modifier and Type | Method and Description |
---|---|
Optional<CatalogBaseTable> |
CatalogManager.ResolvedTable.getCatalogTable() |
Modifier and Type | Method and Description |
---|---|
void |
GenericInMemoryCatalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists) |
void |
Catalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists)
Modify an existing table or view.
|
void |
GenericInMemoryCatalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists) |
void |
Catalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists)
Create a new table or view.
|
Modifier and Type | Method and Description |
---|---|
CatalogBaseTable |
HiveCatalog.getTable(ObjectPath tablePath) |
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newCatalogTable,
boolean ignoreIfNotExists) |
void |
HiveCatalog.createTable(ObjectPath tablePath,
CatalogBaseTable table,
boolean ignoreIfExists) |
protected static org.apache.hadoop.hive.metastore.api.Table |
HiveCatalog.instantiateHiveTable(ObjectPath tablePath,
CatalogBaseTable table) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.