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 © 2022 The Apache Software Foundation. All rights reserved.