org.apache.datasketches.hive.frequencies

Class DataToItemsSketchUDAF.DataToItemsSketchEvaluator<T>

java.lang.Object

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

org.apache.datasketches.hive.frequencies.DataToItemsSketchUDAF.DataToItemsSketchEvaluator<T>

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

DataToItemsSketchUDAF<T>

public abstract static class DataToItemsSketchUDAF.DataToItemsSketchEvaluator<T>
extends org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

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 and Description
protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector	inputObjectInspector

Fields inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

partitionEvaluator

Constructor Summary

Constructors

Constructor and Description
DataToItemsSketchEvaluator(org.apache.datasketches.ArrayOfItemsSerDe<T> serDe)

Method Summary

Modifier and Type	Method and Description
abstract T	extractValue(Object data, org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector objectInspector)
org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer	getNewAggregationBuffer()
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)
void	iterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf, Object[] data)
void	merge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf, Object data)
void	reset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf)
Object	terminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf)
Object	terminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf)

Methods inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

aggregate, close, configure, createPartitionEvaluator, evaluate, getExprString, getPartitionWindowingEvaluator, getWindowingEvaluator, isEstimable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inputObjectInspector

protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector inputObjectInspector

Constructor Detail

DataToItemsSketchEvaluator

public DataToItemsSketchEvaluator(org.apache.datasketches.ArrayOfItemsSerDe<T> serDe)

Method Detail

init

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

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

iterate

public void iterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf,
                    Object[] data)
             throws org.apache.hadoop.hive.ql.metadata.HiveException

Specified by:

iterate in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

extractValue

public abstract T extractValue(Object data,
                               org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector objectInspector)
                        throws org.apache.hadoop.hive.ql.metadata.HiveException

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:

reset in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

terminatePartial

public Object terminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer buf)
                        throws org.apache.hadoop.hive.ql.metadata.HiveException

Specified by:

terminatePartial in class org.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:

merge in class org.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 buf)
                 throws org.apache.hadoop.hive.ql.metadata.HiveException

Specified by:

terminate in class org.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:

getNewAggregationBuffer in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException