public class LongColumnStatsAggregator extends ColumnStatsAggregator implements IExtrapolatePartStatus
ndvTuner, useDensityFunctionForNDVEstimation
Constructor and Description |
---|
LongColumnStatsAggregator() |
Modifier and Type | Method and Description |
---|---|
ColumnStatisticsObj |
aggregate(List<MetaStoreServerUtils.ColStatsObjWithSourceInfo> colStatsWithSourceInfo,
List<String> partNames,
boolean areAllPartsFound) |
void |
extrapolate(ColumnStatisticsData extrapolateData,
int numParts,
int numPartsWithStats,
Map<String,Double> adjustedIndexMap,
Map<String,ColumnStatisticsData> adjustedStatsMap,
double densityAvg) |
public ColumnStatisticsObj aggregate(List<MetaStoreServerUtils.ColStatsObjWithSourceInfo> colStatsWithSourceInfo, List<String> partNames, boolean areAllPartsFound) throws MetaException
aggregate
in class ColumnStatsAggregator
MetaException
public void extrapolate(ColumnStatisticsData extrapolateData, int numParts, int numPartsWithStats, Map<String,Double> adjustedIndexMap, Map<String,ColumnStatisticsData> adjustedStatsMap, double densityAvg)
extrapolate
in interface IExtrapolatePartStatus
extrapolateData
- it will carry back the specific stats, e.g., DOUBLE_STATS or
LONG_STATSnumParts
- the total number of partitionsnumPartsWithStats
- the number of partitions that have statsadjustedIndexMap
- the partition name to index mapadjustedStatsMap
- the partition name to its stats mapdensityAvg
- the average of ndv density, which is useful when
useDensityFunctionForNDVEstimation is true.Copyright © 2022 The Apache Software Foundation. All rights reserved.