Package | Description |
---|---|
org.apache.flink.connector.jdbc.catalog | |
org.apache.flink.table.api.internal | |
org.apache.flink.table.catalog | |
org.apache.flink.table.catalog.hive |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJdbcCatalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists) |
void |
AbstractJdbcCatalog.alterTableColumnStatistics(ObjectPath tablePath,
CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists) |
void |
AbstractJdbcCatalog.alterTableStatistics(ObjectPath tablePath,
CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists) |
void |
AbstractJdbcCatalog.createPartition(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec,
CatalogPartition partition,
boolean ignoreIfExists) |
void |
AbstractJdbcCatalog.dropTable(ObjectPath tablePath,
boolean ignoreIfNotExists) |
CatalogBaseTable |
JdbcCatalog.getTable(ObjectPath tablePath) |
CatalogBaseTable |
AbstractJdbcCatalog.getTable(ObjectPath tablePath) |
CatalogColumnStatistics |
AbstractJdbcCatalog.getTableColumnStatistics(ObjectPath tablePath) |
CatalogTableStatistics |
AbstractJdbcCatalog.getTableStatistics(ObjectPath tablePath) |
List<CatalogPartitionSpec> |
AbstractJdbcCatalog.listPartitions(ObjectPath tablePath) |
List<CatalogPartitionSpec> |
AbstractJdbcCatalog.listPartitions(ObjectPath tablePath,
CatalogPartitionSpec partitionSpec) |
List<CatalogPartitionSpec> |
AbstractJdbcCatalog.listPartitionsByFilter(ObjectPath tablePath,
List<Expression> filters) |
void |
AbstractJdbcCatalog.renameTable(ObjectPath tablePath,
String newTableName,
boolean ignoreIfNotExists) |
Modifier and Type | Method and Description |
---|---|
static TableResultInternal |
AnalyzeTableUtil.analyzeTable(TableEnvironmentImpl tableEnv,
AnalyzeTableOperation operation) |
Modifier and Type | Method and Description |
---|---|
void |
GenericInMemoryCatalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists) |
void |
Catalog.alterTable(ObjectPath tablePath,
CatalogBaseTable newTable,
boolean ignoreIfNotExists)
Modifies 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)
|
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.
|
List<CatalogPartitionSpec> |
GenericInMemoryCatalog.listPartitionsByFilter(ObjectPath tablePath,
List<Expression> filters) |
List<CatalogPartitionSpec> |
Catalog.listPartitionsByFilter(ObjectPath tablePath,
List<Expression> filters)
Get CatalogPartitionSpec of partitions by expression filters 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) |
List<CatalogPartitionSpec> |
HiveCatalog.listPartitionsByFilter(ObjectPath tablePath,
List<Expression> expressions) |
void |
HiveCatalog.renameTable(ObjectPath tablePath,
String newTableName,
boolean ignoreIfNotExists) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.