Class DataToSketchUDAF.DataToSketchEvaluator

  • All Implemented Interfaces:
    Closeable, AutoCloseable
    Enclosing class:
    DataToSketchUDAF

    public static class DataToSketchUDAF.DataToSketchEvaluator
    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 inputInspector_  
      protected org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector intermediateInspector_  
      protected static String LG_K_FIELD  
      protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector lgKInspector_  
      protected static String SEED_FIELD  
      protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector seedInspector_  
      protected static String SKETCH_FIELD  
      • Fields inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

        partitionEvaluator
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      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 agg, Object[] parameters)  
      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

      • inputInspector_

        protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector inputInspector_
      • lgKInspector_

        protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector lgKInspector_
      • seedInspector_

        protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector seedInspector_
      • intermediateInspector_

        protected org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector intermediateInspector_
    • Constructor Detail

      • DataToSketchEvaluator

        public DataToSketchEvaluator()
    • Method Detail

      • 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
      • 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
        Overrides:
        init in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
        Throws:
        org.apache.hadoop.hive.ql.metadata.HiveException
      • iterate

        public void iterate​(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg,
                            Object[] parameters)
                     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
      • 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
      • 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