This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from fda2bdd05c7 [FLINK-28886][python] Support HybridSource in Python
DataStream API
add 6fb49b1d708 [FLINK-28778][SQL/API] Bulk fetch of table and column
statistics for given partitions
No new revisions were added by this update.
Summary of changes:
.../connectors/hive/util/HivePartitionUtils.java | 22 ++
.../flink/table/catalog/hive/HiveCatalog.java | 164 ++++++++---
.../table/catalog/hive/util/HiveStatsUtil.java | 274 +++++++++++++++++++
.../catalog/hive/HiveCatalogHiveMetadataTest.java | 302 +++++++++++++++++++++
flink-python/pyflink/table/catalog.py | 34 +++
.../table/catalog/GenericInMemoryCatalogTest.java | 72 +++++
.../org/apache/flink/table/catalog/Catalog.java | 53 ++++
.../stats/CatalogColumnStatisticsDataBinary.java | 7 +-
.../stats/CatalogColumnStatisticsDataBoolean.java | 7 +-
.../stats/CatalogColumnStatisticsDataDate.java | 7 +-
.../stats/CatalogColumnStatisticsDataDouble.java | 7 +-
.../stats/CatalogColumnStatisticsDataLong.java | 7 +-
.../stats/CatalogColumnStatisticsDataString.java | 7 +-
.../catalog/stats/CatalogTableStatistics.java | 1 +
.../apache/flink/table/plan/stats/ColumnStats.java | 7 +
.../apache/flink/table/plan/stats/TableStats.java | 17 +-
.../flink/table/factories/TestCatalogFactory.java | 17 +-
.../utils/CatalogTableStatisticsConverter.java | 22 ++
.../program/FlinkRecomputeStatisticsProgram.java | 53 ++--
19 files changed, 996 insertions(+), 84 deletions(-)
