public class DoubleColumnStatsAggregator extends ColumnStatsAggregator implements IExtrapolatePartStatus
numBitVectors, useDensityFunctionForNDVEstimation
Constructor and Description |
---|
DoubleColumnStatsAggregator() |
Modifier and Type | Method and Description |
---|---|
ColumnStatisticsObj |
aggregate(String colName,
List<String> partNames,
List<ColumnStatistics> css) |
void |
extrapolate(ColumnStatisticsData extrapolateData,
int numParts,
int numPartsWithStats,
Map<String,Double> adjustedIndexMap,
Map<String,ColumnStatisticsData> adjustedStatsMap,
double densityAvg) |
public ColumnStatisticsObj aggregate(String colName, List<String> partNames, List<ColumnStatistics> css) 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 © 2016 The Apache Software Foundation. All rights reserved.