Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.catalog.hive |
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.alterTableColumnStatistics(ObjectPath tablePath,
CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists) |
void |
Catalog.alterTableColumnStatistics(ObjectPath tablePath,
CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists)
Update the column statistics of a table.
|
void |
GenericInMemoryCatalog.alterTableStatistics(ObjectPath tablePath,
CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists) |
void |
Catalog.alterTableStatistics(ObjectPath tablePath,
CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists)
Update the statistics of a table.
|
void |
GenericInMemoryCatalog.createPartition(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogPartition partition,
boolean ignoreIfExists) |
void |
Catalog.createPartition(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogPartition partition,
boolean ignoreIfExists)
Create a partition.
|
void |
GenericInMemoryCatalog.dropTable(ObjectPath tablePath,
boolean ignoreIfNotExists) |
void |
Catalog.dropTable(ObjectPath tablePath,
boolean ignoreIfNotExists)
Drop a table or view.
|
CatalogBaseTable |
GenericInMemoryCatalog.getTable(ObjectPath tablePath) |
CatalogBaseTable |
Catalog.getTable(ObjectPath tablePath)
Get a CatalogTable or CatalogView identified by tablePath.
|
CatalogColumnStatistics |
GenericInMemoryCatalog.getTableColumnStatistics(ObjectPath tablePath) |
CatalogColumnStatistics |
Catalog.getTableColumnStatistics(ObjectPath tablePath)
Get the column statistics of a table.
|
CatalogTableStatistics |
GenericInMemoryCatalog.getTableStatistics(ObjectPath tablePath) |
CatalogTableStatistics |
Catalog.getTableStatistics(ObjectPath tablePath)
Get the statistics of a table.
|
List<CatalogPartitionSpec> |
GenericInMemoryCatalog.listPartitions(ObjectPath tablePath) |
List<CatalogPartitionSpec> |
Catalog.listPartitions(ObjectPath tablePath)
Get CatalogPartitionSpec of all partitions of the table.
|
List<CatalogPartitionSpec> |
GenericInMemoryCatalog.listPartitions(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec) |
List<CatalogPartitionSpec> |
Catalog.listPartitions(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec)
Get CatalogPartitionSpec of all partitions that is under the given CatalogPartitionSpec in the table.
|
void |
GenericInMemoryCatalog.renameTable(ObjectPath tablePath,
String newTableName,
boolean ignoreIfNotExists) |
void |
Catalog.renameTable(ObjectPath tablePath,
String newTableName,
boolean ignoreIfNotExists)
Rename an existing table or view.
|
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newCatalogTable,
boolean ignoreIfNotExists) |
void |
HiveCatalog.alterTableColumnStatistics(ObjectPath tablePath,
CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists) |
void |
HiveCatalog.alterTableStatistics(ObjectPath tablePath,
CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists) |
void |
HiveCatalog.createPartition(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogPartition partition,
boolean ignoreIfExists) |
void |
HiveCatalog.dropTable(ObjectPath tablePath,
boolean ignoreIfNotExists) |
org.apache.hadoop.hive.metastore.api.Table |
HiveCatalog.getHiveTable(ObjectPath tablePath) |
CatalogBaseTable |
HiveCatalog.getTable(ObjectPath tablePath) |
CatalogColumnStatistics |
HiveCatalog.getTableColumnStatistics(ObjectPath tablePath) |
CatalogTableStatistics |
HiveCatalog.getTableStatistics(ObjectPath tablePath) |
List<CatalogPartitionSpec> |
HiveCatalog.listPartitions(ObjectPath tablePath) |
List<CatalogPartitionSpec> |
HiveCatalog.listPartitions(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec) |
void |
HiveCatalog.renameTable(ObjectPath tablePath,
String newTableName,
boolean ignoreIfNotExists) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.