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 TableStats	convertToAccumulatedTableStates(List<CatalogTableStatistics> tableStatisticsList, List<CatalogColumnStatistics> catalogColumnStatisticsList, Set<String> partitionKeys)
static Map<String,ColumnStats>	convertToColumnStatsMap(Map<String,CatalogColumnStatisticsDataBase> columnStatisticsData)
static TableStats	convertToTableStats(CatalogTableStatistics tableStatistics, 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 TableStats convertToTableStats(CatalogTableStatistics tableStatistics,
                                             CatalogColumnStatistics columnStatistics)

convertToAccumulatedTableStates

public static TableStats convertToAccumulatedTableStates(List<CatalogTableStatistics> tableStatisticsList,
                                                         List<CatalogColumnStatistics> catalogColumnStatisticsList,
                                                         Set<String> partitionKeys)

convertToColumnStatsMap

@VisibleForTesting
public static Map<String,ColumnStats> convertToColumnStatsMap(Map<String,CatalogColumnStatisticsDataBase> columnStatisticsData)