Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.catalog.hive | |
org.apache.flink.table.catalog.stats | |
org.apache.flink.table.util |
Modifier and Type | Method and Description |
---|---|
CatalogTableStatistics |
GenericInMemoryCatalog.getPartitionStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec) |
CatalogTableStatistics |
Catalog.getPartitionStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec)
Get the statistics of a partition.
|
CatalogTableStatistics |
GenericInMemoryCatalog.getTableStatistics(ObjectPath tablePath) |
CatalogTableStatistics |
Catalog.getTableStatistics(ObjectPath tablePath)
Get the statistics of a table.
|
Modifier and Type | Method and Description |
---|---|
void |
GenericInMemoryCatalog.alterPartitionStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogTableStatistics partitionStatistics,
boolean ignoreIfNotExists) |
void |
Catalog.alterPartitionStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogTableStatistics partitionStatistics,
boolean ignoreIfNotExists)
Update the statistics of a table partition.
|
void |
GenericInMemoryCatalog.alterTableStatistics(ObjectPath tablePath,
CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists) |
void |
Catalog.alterTableStatistics(ObjectPath tablePath,
CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists)
Update the statistics of a table.
|
Modifier and Type | Method and Description |
---|---|
CatalogTableStatistics |
HiveCatalog.getPartitionStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec) |
CatalogTableStatistics |
HiveCatalog.getTableStatistics(ObjectPath tablePath) |
Modifier and Type | Method and Description |
---|---|
void |
HiveCatalog.alterPartitionStatistics(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogTableStatistics partitionStatistics,
boolean ignoreIfNotExists) |
void |
HiveCatalog.alterTableStatistics(ObjectPath tablePath,
CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists) |
Modifier and Type | Field and Description |
---|---|
static CatalogTableStatistics |
CatalogTableStatistics.UNKNOWN |
Modifier and Type | Method and Description |
---|---|
CatalogTableStatistics |
CatalogTableStatistics.copy()
Create a deep copy of "this" instance.
|
Modifier and Type | Method and Description |
---|---|
static TableStats |
CatalogTableStatisticsConverter.convertToTableStats(CatalogTableStatistics tableStatistics,
CatalogColumnStatistics columnStatistics) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.