org.apache.flink.table.planner.utils

Class CatalogTableStatisticsConverter

java.lang.Object

org.apache.flink.table.planner.utils.CatalogTableStatisticsConverter

public class CatalogTableStatisticsConverter
extends Object

Utility class for converting CatalogTableStatistics and CatalogColumnStatistics to TableStats.

Constructor Summary

Constructors

Constructor and Description
CatalogTableStatisticsConverter()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.table.plan.stats.TableStats	convertToAccumulatedTableStates(List<org.apache.flink.table.catalog.stats.CatalogTableStatistics> tableStatisticsList, List<org.apache.flink.table.catalog.stats.CatalogColumnStatistics> catalogColumnStatisticsList, Set<String> partitionKeys)
static Map<String,org.apache.flink.table.plan.stats.ColumnStats>	convertToColumnStatsMap(Map<String,org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataBase> columnStatisticsData)
static org.apache.flink.table.plan.stats.TableStats	convertToTableStats(org.apache.flink.table.catalog.stats.CatalogTableStatistics tableStatistics, org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CatalogTableStatisticsConverter

public CatalogTableStatisticsConverter()

Method Detail

convertToTableStats

public static org.apache.flink.table.plan.stats.TableStats convertToTableStats(org.apache.flink.table.catalog.stats.CatalogTableStatistics tableStatistics,
                                                                               org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics)

convertToAccumulatedTableStates

public static org.apache.flink.table.plan.stats.TableStats convertToAccumulatedTableStates(List<org.apache.flink.table.catalog.stats.CatalogTableStatistics> tableStatisticsList,
                                                                                           List<org.apache.flink.table.catalog.stats.CatalogColumnStatistics> catalogColumnStatisticsList,
                                                                                           Set<String> partitionKeys)

convertToColumnStatsMap

@VisibleForTesting
public static Map<String,org.apache.flink.table.plan.stats.ColumnStats> convertToColumnStatsMap(Map<String,org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataBase> columnStatisticsData)