Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
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 | Class and Description |
---|---|
class |
PTFRollingPartition |
Modifier and Type | Method and Description |
---|---|
static PTFPartition |
PTFPartition.create(org.apache.hadoop.conf.Configuration cfg,
AbstractSerDe serDe,
StructObjectInspector inputOI,
StructObjectInspector outputOI) |
PTFPartition |
PTFPartition.PTFPartitionIterator.getPartition() |
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 PTFPartition |
TableFunctionEvaluator.outputPartition |
protected PTFPartition |
BasePartitionEvaluator.partition |
Modifier and Type | Method and Description |
---|---|
protected PTFPartition |
TableFunctionEvaluator._transformRawInput(PTFPartition iPart) |
protected PTFPartition |
NoopWithMap._transformRawInput(PTFPartition iPart) |
PTFPartition |
Noop.execute(PTFPartition iPart) |
PTFPartition |
TableFunctionEvaluator.execute(PTFPartition iPart) |
protected PTFPartition |
TableFunctionEvaluator.transformRawInput(PTFPartition iPart) |
Modifier and Type | Method and Description |
---|---|
protected PTFPartition |
TableFunctionEvaluator._transformRawInput(PTFPartition iPart) |
protected PTFPartition |
NoopWithMap._transformRawInput(PTFPartition iPart) |
abstract int |
ValueBoundaryScanner.computeEnd(int rowIdx,
PTFPartition p) |
abstract int |
ValueBoundaryScanner.computeStart(int rowIdx,
PTFPartition p) |
void |
MatchPath.execute(PTFPartition.PTFPartitionIterator<Object> pItr,
PTFPartition outP) |
protected void |
Noop.execute(PTFPartition.PTFPartitionIterator<Object> pItr,
PTFPartition oPart) |
protected abstract void |
TableFunctionEvaluator.execute(PTFPartition.PTFPartitionIterator<Object> pItr,
PTFPartition oPart) |
void |
WindowingTableFunction.execute(PTFPartition.PTFPartitionIterator<Object> pItr,
PTFPartition outP) |
PTFPartition |
Noop.execute(PTFPartition iPart) |
PTFPartition |
TableFunctionEvaluator.execute(PTFPartition iPart) |
protected static BasePartitionEvaluator.Range |
BasePartitionEvaluator.getRange(WindowFrameDef winFrame,
int currRow,
PTFPartition p) |
protected PTFPartition |
TableFunctionEvaluator.transformRawInput(PTFPartition iPart) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.