| Package | Description |
|---|---|
| org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
| org.apache.hadoop.hive.ql.parse | |
| org.apache.hadoop.hive.ql.plan | |
| org.apache.hadoop.hive.ql.udf.ptf |
| Modifier and Type | Method and Description |
|---|---|
static void |
PTFOperator.connectLeadLagFunctionsToPartition(LeadLagInfo leadLagInfo,
PTFPartition.PTFPartitionIterator<Object> pItr) |
| Modifier and Type | Method and Description |
|---|---|
static ExprNodeEvaluator |
WindowingExprNodeEvaluatorFactory.get(LeadLagInfo llInfo,
ExprNodeDesc desc) |
| Modifier and Type | Method and Description |
|---|---|
LeadLagInfo |
PTFDesc.getLlInfo() |
| Modifier and Type | Method and Description |
|---|---|
void |
PTFDesc.setLlInfo(LeadLagInfo llInfo) |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
BasePartitionEvaluator.calcFunctionValue(PTFPartition.PTFPartitionIterator<Object> pItr,
LeadLagInfo leadLagInfo)
Given a partition iterator, calculate the function value
|
Object |
BasePartitionEvaluator.iterate(int currentRow,
LeadLagInfo leadLagInfo)
Given the current row, get the aggregation for the window
|
Object |
BasePartitionEvaluator.SumPartitionEvaluator.iterate(int currentRow,
LeadLagInfo leadLagInfo) |
Object |
BasePartitionEvaluator.AvgPartitionEvaluator.iterate(int currentRow,
LeadLagInfo leadLagInfo) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.