Class 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 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 Description
      DataToItemsSketchEvaluator​(org.apache.datasketches.common.ArrayOfItemsSerDe<T> serDe)  
    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method 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, estimate, evaluate, getExprString, getPartitionWindowingEvaluator, getWindowingEvaluator, isEstimable
    • Field Detail

      • inputObjectInspector

        protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector inputObjectInspector
    • Constructor Detail

      • DataToItemsSketchEvaluator

        public DataToItemsSketchEvaluator​(org.apache.datasketches.common.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