public abstract class UnionEvaluator
extends 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
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector |
inputObjectInspector |
protected org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector |
intermediateObjectInspector |
protected static String |
NOMINAL_ENTRIES_FIELD |
protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector |
nominalEntriesObjectInspector |
protected static String |
SEED_FIELD |
protected org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector |
seedObjectInspector |
protected static String |
SKETCH_FIELD |
Constructor and Description |
---|
UnionEvaluator() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer |
getNewAggregationBuffer() |
void |
merge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg,
Object partial) |
void |
reset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) |
Object |
terminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) |
Object |
terminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) |
protected static final String NOMINAL_ENTRIES_FIELD
protected static final String SEED_FIELD
protected static final String SKETCH_FIELD
protected transient org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector inputObjectInspector
protected transient org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector nominalEntriesObjectInspector
protected transient org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector seedObjectInspector
protected transient org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector intermediateObjectInspector
public Object terminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) throws org.apache.hadoop.hive.ql.metadata.HiveException
terminatePartial
in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
org.apache.hadoop.hive.ql.metadata.HiveException
public void merge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg, Object partial) throws org.apache.hadoop.hive.ql.metadata.HiveException
merge
in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
org.apache.hadoop.hive.ql.metadata.HiveException
public Object terminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) throws org.apache.hadoop.hive.ql.metadata.HiveException
terminate
in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
org.apache.hadoop.hive.ql.metadata.HiveException
public void reset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer agg) throws org.apache.hadoop.hive.ql.metadata.HiveException
reset
in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
org.apache.hadoop.hive.ql.metadata.HiveException
public org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer getNewAggregationBuffer() throws org.apache.hadoop.hive.ql.metadata.HiveException
getNewAggregationBuffer
in class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator
org.apache.hadoop.hive.ql.metadata.HiveException
GenericUDAFEvaluator.getNewAggregationBuffer()
Copyright © 2015–2019 The Apache Software Foundation. All rights reserved.