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.AbstractAggregationBufferestimate in class GenericUDAFEvaluator.AbstractAggregationBufferprotected void initNDVEstimator(String func, int numBitVectors)
protected abstract void update(Object p, PrimitiveObjectInspector inputOI)
public void reset(String type) throws HiveException
HiveExceptionCopyright © 2019 The Apache Software Foundation. All Rights Reserved.