public static class UnionSketchUDAF.UnionSketchUDAFEvaluator extends UnionEvaluator
org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AbstractAggregationBuffer, org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer, org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationType, org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.Mode
inputObjectInspector, intermediateObjectInspector, NOMINAL_ENTRIES_FIELD, nominalEntriesObjectInspector, SEED_FIELD, seedObjectInspector, SKETCH_FIELD
Constructor and Description |
---|
UnionSketchUDAFEvaluator() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector |
init(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.Mode mode,
org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] parameters)
Receives the passed in argument object inspectors and returns the desired
return type's object inspector to inform hive of return type of UDAF.
|
void |
iterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg,
Object[] parameters)
Add the incoming sketch into the internal state.
|
getNewAggregationBuffer, merge, reset, terminate, terminatePartial
public org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector init(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.Mode mode, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] parameters) throws org.apache.hadoop.hive.ql.metadata.HiveException
init
in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
mode
- Mode (i.e. PARTIAL 1, COMPLETE...) for determining input/output
object inspector type.parameters
- List of object inspectors for input arguments.org.apache.hadoop.hive.ql.metadata.HiveException
public void iterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg, Object[] parameters) throws org.apache.hadoop.hive.ql.metadata.HiveException
iterate
in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
agg
- aggregation buffer storing intermediate results.parameters
- sketches in the form of Object passed in to be merged.org.apache.hadoop.hive.ql.metadata.HiveException
Copyright © 2015–2019 The Apache Software Foundation. All rights reserved.