Package | Description |
---|---|
org.apache.hadoop.hive.ql.udf.generic |
Standard toolkit and framework for generic User-defined functions.
|
org.apache.hadoop.hive.ql.udf.ptf |
Modifier and Type | Field and Description |
---|---|
protected BasePartitionEvaluator |
GenericUDAFEvaluator.partitionEvaluator |
Modifier and Type | Method and Description |
---|---|
protected BasePartitionEvaluator |
GenericUDAFSum.GenericUDAFSumHiveDecimal.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFSum.GenericUDAFSumDouble.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFSum.GenericUDAFSumLong.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFAverage.GenericUDAFAverageEvaluatorDouble.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFEvaluator.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI)
This class needs to be overridden by the child class to implement function
specific evaluator.
|
BasePartitionEvaluator |
GenericUDAFEvaluator.getPartitionWindowingEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI)
When evaluating an aggregates over a fixed Window, streaming is not possible
especially for RANGE Window type.
|
Modifier and Type | Class and Description |
---|---|
static class |
BasePartitionEvaluator.AvgPartitionDoubleEvaluator |
static class |
BasePartitionEvaluator.AvgPartitionEvaluator<ResultType extends org.apache.hadoop.io.Writable>
The partition evalulator for average function
|
static class |
BasePartitionEvaluator.AvgPartitionHiveDecimalEvaluator |
static class |
BasePartitionEvaluator.SumPartitionDoubleEvaluator |
static class |
BasePartitionEvaluator.SumPartitionEvaluator<ResultType extends org.apache.hadoop.io.Writable>
The base type for sum operator evaluator when a partition data is available
and streaming process is not possible.
|
static class |
BasePartitionEvaluator.SumPartitionHiveDecimalEvaluator |
static class |
BasePartitionEvaluator.SumPartitionLongEvaluator |
Copyright © 2022 The Apache Software Foundation. All rights reserved.