Class UnionEvaluator
- java.lang.Object
-
- org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
-
- org.apache.datasketches.hive.theta.UnionEvaluator
-
- All Implemented Interfaces:
Closeable,AutoCloseable
- Direct Known Subclasses:
DataToSketchUDAF.DataToSketchEvaluator,UnionSketchUDAF.UnionSketchUDAFEvaluator
public abstract class UnionEvaluator extends org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluatorCommon code for DataToSketchUDAF and UnionSketchUDAF
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
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
-
-
Field Summary
Fields Modifier and Type Field Description protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspectorinputObjectInspectorprotected org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspectorintermediateObjectInspectorprotected static StringNOMINAL_ENTRIES_FIELDprotected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspectornominalEntriesObjectInspectorprotected static StringSEED_FIELDprotected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspectorseedObjectInspectorprotected static StringSKETCH_FIELD
-
Constructor Summary
Constructors Constructor Description UnionEvaluator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffergetNewAggregationBuffer()voidmerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg, Object partial)voidreset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg)Objectterminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg)ObjectterminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg)
-
-
-
Field Detail
-
NOMINAL_ENTRIES_FIELD
protected static final String NOMINAL_ENTRIES_FIELD
- See Also:
- Constant Field Values
-
SEED_FIELD
protected static final String SEED_FIELD
- See Also:
- Constant Field Values
-
SKETCH_FIELD
protected static final String SKETCH_FIELD
- See Also:
- Constant Field Values
-
inputObjectInspector
protected transient org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector inputObjectInspector
-
nominalEntriesObjectInspector
protected transient org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector nominalEntriesObjectInspector
-
seedObjectInspector
protected transient org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector seedObjectInspector
-
intermediateObjectInspector
protected transient org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector intermediateObjectInspector
-
-
Method Detail
-
terminatePartial
public Object terminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) throws org.apache.hadoop.hive.ql.metadata.HiveException
- Specified by:
terminatePartialin classorg.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator- Throws:
org.apache.hadoop.hive.ql.metadata.HiveException
-
merge
public void merge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg, Object partial) throws org.apache.hadoop.hive.ql.metadata.HiveException- Specified by:
mergein classorg.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator- Throws:
org.apache.hadoop.hive.ql.metadata.HiveException
-
terminate
public Object terminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) throws org.apache.hadoop.hive.ql.metadata.HiveException
- Specified by:
terminatein classorg.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator- Throws:
org.apache.hadoop.hive.ql.metadata.HiveException
-
reset
public void reset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) throws org.apache.hadoop.hive.ql.metadata.HiveException- Specified by:
resetin classorg.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator- Throws:
org.apache.hadoop.hive.ql.metadata.HiveException
-
getNewAggregationBuffer
public org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer getNewAggregationBuffer() throws org.apache.hadoop.hive.ql.metadata.HiveException- Specified by:
getNewAggregationBufferin classorg.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator- Throws:
org.apache.hadoop.hive.ql.metadata.HiveException- See Also:
GenericUDAFEvaluator.getNewAggregationBuffer()
-
-