Package | Description |
---|---|
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan | |
org.apache.hadoop.hive.ql.plan.ptf | |
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 | Method and Description |
---|---|
PTFExpressionDef |
PTFTranslator.buildExpressionDef(ShapeDetails inpShape,
ASTNode arg) |
Modifier and Type | Method and Description |
---|---|
protected void |
PTFDeserializer.initialize(PTFExpressionDef eDef,
ShapeDetails inpShape) |
Modifier and Type | Class and Description |
---|---|
class |
OrderExpressionDef |
class |
WindowExpressionDef |
class |
WindowFunctionDef |
Modifier and Type | Method and Description |
---|---|
List<PTFExpressionDef> |
PartitionedTableFunctionDef.getArgs() |
List<PTFExpressionDef> |
WindowFunctionDef.getArgs() |
List<PTFExpressionDef> |
PartitionDef.getExpressions() |
Modifier and Type | Method and Description |
---|---|
void |
PartitionedTableFunctionDef.addArg(PTFExpressionDef arg) |
void |
WindowFunctionDef.addArg(PTFExpressionDef arg) |
void |
PartitionDef.addExpression(PTFExpressionDef e) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionedTableFunctionDef.setArgs(List<PTFExpressionDef> args) |
void |
WindowFunctionDef.setArgs(List<PTFExpressionDef> args) |
void |
PartitionDef.setExpressions(List<PTFExpressionDef> expressions) |
Constructor and Description |
---|
OrderExpressionDef(PTFExpressionDef e) |
PTFExpressionDef(PTFExpressionDef e) |
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 | Field and Description |
---|---|
protected List<PTFExpressionDef> |
BasePartitionEvaluator.parameters |
Copyright © 2021 The Apache Software Foundation. All rights reserved.