Class UnionDoubleSummarySketchUDAF.UnionDoubleSummarySketchEvaluator
- java.lang.Object
-
- org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
-
- org.apache.datasketches.hive.tuple.UnionSketchUDAF.UnionSketchEvaluator<org.apache.datasketches.tuple.adouble.DoubleSummary>
-
- org.apache.datasketches.hive.tuple.UnionDoubleSummarySketchUDAF.UnionDoubleSummarySketchEvaluator
-
- All Implemented Interfaces:
Closeable,AutoCloseable
- Enclosing class:
- UnionDoubleSummarySketchUDAF
public static class UnionDoubleSummarySketchUDAF.UnionDoubleSummarySketchEvaluator extends UnionSketchUDAF.UnionSketchEvaluator<org.apache.datasketches.tuple.adouble.DoubleSummary>
-
-
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.StructObjectInspectorintermediateInspector_protected static StringNOMINAL_NUM_ENTRIES_FIELDprotected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspectornominalNumEntriesInspector_protected static StringSKETCH_FIELD
-
Constructor Summary
Constructors Constructor Description UnionDoubleSummarySketchEvaluator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.datasketches.tuple.SummaryDeserializer<org.apache.datasketches.tuple.adouble.DoubleSummary>getSummaryDeserializer()Get an instance of SummaryDeserializerprotected org.apache.datasketches.tuple.SummaryFactory<org.apache.datasketches.tuple.adouble.DoubleSummary>getSummaryFactory(Object[] data)Get an instance of SummaryFactory possibly parameterized based on the original input array of objects.protected org.apache.datasketches.tuple.SummarySetOperations<org.apache.datasketches.tuple.adouble.DoubleSummary>getSummarySetOperationsForIterate(Object[] data)Get an instance of SummarySetOperations possibly parameterized based on the original input array of objects.protected org.apache.datasketches.tuple.SummarySetOperations<org.apache.datasketches.tuple.adouble.DoubleSummary>getSummarySetOperationsForMerge(Object data)Get an instance of SummarySetOperations possibly parameterized based on the intermediate data object.protected voidinitializeState(org.apache.datasketches.hive.tuple.UnionState<S> state, Object data)voidmerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf, Object data)voidreset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf)Objectterminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf)ObjectterminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf)-
Methods inherited from class org.apache.datasketches.hive.tuple.UnionSketchUDAF.UnionSketchEvaluator
getNewAggregationBuffer, init, initializeState, iterate
-
-
-
-
Field Detail
-
NOMINAL_NUM_ENTRIES_FIELD
protected static final String NOMINAL_NUM_ENTRIES_FIELD
- See Also:
- Constant Field Values
-
SKETCH_FIELD
protected static final String SKETCH_FIELD
- See Also:
- Constant Field Values
-
nominalNumEntriesInspector_
protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector nominalNumEntriesInspector_
-
intermediateInspector_
protected org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector intermediateInspector_
-
-
Method Detail
-
getSummaryDeserializer
protected org.apache.datasketches.tuple.SummaryDeserializer<org.apache.datasketches.tuple.adouble.DoubleSummary> getSummaryDeserializer()
Get an instance of SummaryDeserializer- Returns:
- SummaryDeserializer
-
getSummaryFactory
protected org.apache.datasketches.tuple.SummaryFactory<org.apache.datasketches.tuple.adouble.DoubleSummary> getSummaryFactory(Object[] data)
Get an instance of SummaryFactory possibly parameterized based on the original input array of objects. Might be called once during the first call to iterate.- Parameters:
data- original input array of objects- Returns:
- an instance of SummaryFactory
-
getSummarySetOperationsForIterate
protected org.apache.datasketches.tuple.SummarySetOperations<org.apache.datasketches.tuple.adouble.DoubleSummary> getSummarySetOperationsForIterate(Object[] data)
Get an instance of SummarySetOperations possibly parameterized based on the original input array of objects. Might be called once during the first call to iterate.- Parameters:
data- original input array of objects- Returns:
- an instance of SummarySetOperations
-
getSummarySetOperationsForMerge
protected org.apache.datasketches.tuple.SummarySetOperations<org.apache.datasketches.tuple.adouble.DoubleSummary> getSummarySetOperationsForMerge(Object data)
Get an instance of SummarySetOperations possibly parameterized based on the intermediate data object. Might be called once during the first call to merge.- Parameters:
data- intermediate data object- Returns:
- an instance of SummarySetOperations
-
terminatePartial
public Object terminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf) 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 buf, Object data) 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
-
initializeState
protected void initializeState(org.apache.datasketches.hive.tuple.UnionState<S> state, Object data)
-
terminate
public Object terminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf) 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 buf) 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
-
-