public static class GenericUDAFLead.GenericUDAFLeadEvaluator extends GenericUDAFLeadLag.GenericUDAFLeadLagEvaluator
GenericUDAFEvaluator.AbstractAggregationBuffer, GenericUDAFEvaluator.AggregationBuffer, GenericUDAFEvaluator.AggregationType, GenericUDAFEvaluator.Mode
partitionEvaluator
Modifier | Constructor and Description |
---|---|
|
GenericUDAFLeadEvaluator() |
protected |
GenericUDAFLeadEvaluator(GenericUDAFLeadLag.GenericUDAFLeadLagEvaluator src) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.hive.ql.udf.generic.LeadLagBuffer |
getNewLLBuffer() |
GenericUDAFEvaluator |
getWindowingEvaluator(WindowFrameDef wFrmDef)
When evaluating an aggregates over a fixed Window, the naive way to compute
results is to compute the aggregate for each row.
|
getAmt, getFnName, getNewAggregationBuffer, init, iterate, merge, reset, setAmt, setFnName, terminate, terminatePartial
aggregate, close, configure, createPartitionEvaluator, estimate, evaluate, getExprString, getPartitionWindowingEvaluator, isEstimable
public GenericUDAFLeadEvaluator()
protected GenericUDAFLeadEvaluator(GenericUDAFLeadLag.GenericUDAFLeadLagEvaluator src)
protected org.apache.hadoop.hive.ql.udf.generic.LeadLagBuffer getNewLLBuffer() throws HiveException
getNewLLBuffer
in class GenericUDAFLeadLag.GenericUDAFLeadLagEvaluator
HiveException
public GenericUDAFEvaluator getWindowingEvaluator(WindowFrameDef wFrmDef)
GenericUDAFEvaluator
This method is called after this Evaluator is initialized. The returned Function must be initialized. It is passed the 'window' of aggregation for each row.
getWindowingEvaluator
in class GenericUDAFEvaluator
wFrmDef
- the Window definition in play for this evaluation.Copyright © 2019 The Apache Software Foundation. All rights reserved.