org.apache.hadoop.hive.metastore.columnstats.aggr

Class DecimalColumnStatsAggregator

java.lang.Object

org.apache.hadoop.hive.metastore.columnstats.aggr.ColumnStatsAggregator

org.apache.hadoop.hive.metastore.columnstats.aggr.DecimalColumnStatsAggregator

All Implemented Interfaces:

IExtrapolatePartStatus

public class DecimalColumnStatsAggregator
extends ColumnStatsAggregator
implements IExtrapolatePartStatus

Field Summary

Fields inherited from class org.apache.hadoop.hive.metastore.columnstats.aggr.ColumnStatsAggregator

ndvTuner, useDensityFunctionForNDVEstimation

Constructor Summary

Constructors

Constructor and Description
DecimalColumnStatsAggregator()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj	aggregate(List<MetaStoreUtils.ColStatsObjWithSourceInfo> colStatsWithSourceInfo, List<String> partNames, boolean areAllPartsFound)
void	extrapolate(org.apache.hadoop.hive.metastore.api.ColumnStatisticsData extrapolateData, int numParts, int numPartsWithStats, Map<String,Double> adjustedIndexMap, Map<String,org.apache.hadoop.hive.metastore.api.ColumnStatisticsData> adjustedStatsMap, double densityAvg)

Methods inherited from class java.lang.Object

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

Constructor Detail

DecimalColumnStatsAggregator

public DecimalColumnStatsAggregator()

Method Detail

aggregate

public org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj aggregate(List<MetaStoreUtils.ColStatsObjWithSourceInfo> colStatsWithSourceInfo,
                                                                          List<String> partNames,
                                                                          boolean areAllPartsFound)
                                                                   throws org.apache.hadoop.hive.metastore.api.MetaException

Specified by:

aggregate in class ColumnStatsAggregator

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

extrapolate

public void extrapolate(org.apache.hadoop.hive.metastore.api.ColumnStatisticsData extrapolateData,
                        int numParts,
                        int numPartsWithStats,
                        Map<String,Double> adjustedIndexMap,
                        Map<String,org.apache.hadoop.hive.metastore.api.ColumnStatisticsData> adjustedStatsMap,
                        double densityAvg)

Specified by:

extrapolate in interface IExtrapolatePartStatus

Parameters:

extrapolateData - it will carry back the specific stats, e.g., DOUBLE_STATS or LONG_STATS

numParts - the total number of partitions

numPartsWithStats - the number of partitions that have stats

adjustedIndexMap - the partition name to index map

adjustedStatsMap - the partition name to its stats map

densityAvg - the average of ndv density, which is useful when useDensityFunctionForNDVEstimation is true.