public abstract class TableFunctionEvaluator
extends java.lang.Object
GenericUDAFEvaluator
. Break up the responsibility of the old AsbtractTableFunction
class into a Resolver and Evaluator.
The Evaluator also holds onto the TableFunctionDef
. This provides information
about the arguments to the function, the shape of the Input partition and the Partitioning details.
The Evaluator is responsible for providing the 2 execute methods:
Modifier and Type | Field and Description |
---|---|
protected StructObjectInspector |
OI |
protected PTFPartition |
outputPartition |
protected PTFDesc |
ptfDesc |
protected StructObjectInspector |
rawInputOI |
protected PTFDesc.PartitionedTableFunctionDef |
tDef |
Constructor and Description |
---|
TableFunctionEvaluator() |
Modifier and Type | Method and Description |
---|---|
protected PTFPartition |
_transformRawInput(PTFPartition iPart) |
protected abstract void |
execute(PTFPartition.PTFPartitionIterator<java.lang.Object> pItr,
PTFPartition oPart) |
PTFPartition |
execute(PTFPartition iPart) |
StructObjectInspector |
getOutputOI() |
protected PTFDesc |
getQueryDef() |
StructObjectInspector |
getRawInputOI() |
PTFDesc.PartitionedTableFunctionDef |
getTableDef() |
boolean |
isTransformsRawInput() |
protected void |
setOutputOI(StructObjectInspector outputOI) |
protected void |
setQueryDef(PTFDesc ptfDesc) |
protected void |
setRawInputOI(StructObjectInspector rawInputOI) |
void |
setTableDef(PTFDesc.PartitionedTableFunctionDef tDef) |
void |
setTransformsRawInput(boolean transformsRawInput) |
PTFPartition |
transformRawInput(PTFPartition iPart) |
protected transient StructObjectInspector OI
protected transient StructObjectInspector rawInputOI
protected PTFDesc.PartitionedTableFunctionDef tDef
protected PTFDesc ptfDesc
protected transient PTFPartition outputPartition
public StructObjectInspector getOutputOI()
protected void setOutputOI(StructObjectInspector outputOI)
public PTFDesc.PartitionedTableFunctionDef getTableDef()
public void setTableDef(PTFDesc.PartitionedTableFunctionDef tDef)
protected PTFDesc getQueryDef()
protected void setQueryDef(PTFDesc ptfDesc)
public StructObjectInspector getRawInputOI()
protected void setRawInputOI(StructObjectInspector rawInputOI)
public boolean isTransformsRawInput()
public void setTransformsRawInput(boolean transformsRawInput)
public PTFPartition execute(PTFPartition iPart) throws HiveException
HiveException
protected abstract void execute(PTFPartition.PTFPartitionIterator<java.lang.Object> pItr, PTFPartition oPart) throws HiveException
HiveException
public PTFPartition transformRawInput(PTFPartition iPart) throws HiveException
HiveException
protected PTFPartition _transformRawInput(PTFPartition iPart) throws HiveException
HiveException
Copyright © 2012 The Apache Software Foundation