public abstract class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg extends GenericUDAFEvaluator.AbstractAggregationBuffer
Modifier and Type | Field and Description |
---|---|
String |
columnType |
long |
countNulls |
V |
max |
V |
min |
NumDistinctValueEstimator |
numDV |
Constructor and Description |
---|
NumericStatsAgg() |
Modifier and Type | Method and Description |
---|---|
int |
estimate()
Estimate the size of memory which is occupied by aggregation buffer.
|
protected void |
initNDVEstimator(String func,
int numBitVectors) |
void |
reset(String type) |
protected Object |
serialize(Object[] result) |
protected Object |
serializePartial(Object[] result) |
protected abstract void |
update(Object p,
PrimitiveObjectInspector inputOI) |
protected abstract void |
updateMax(Object maxValue,
OI maxOI) |
protected abstract void |
updateMin(Object minValue,
OI minOI) |
public String columnType
public V min
public V max
public long countNulls
public NumDistinctValueEstimator numDV
public int estimate()
GenericUDAFEvaluator.AbstractAggregationBuffer
estimate
in class GenericUDAFEvaluator.AbstractAggregationBuffer
protected void initNDVEstimator(String func, int numBitVectors)
protected abstract void update(Object p, PrimitiveObjectInspector inputOI)
public void reset(String type) throws HiveException
HiveException
Copyright © 2022 The Apache Software Foundation. All rights reserved.