org.apache.hadoop.hive.ql.udf.ptf

Class WindowingTableFunction.WindowingTableFunctionResolver

java.lang.Object

org.apache.hadoop.hive.ql.udf.ptf.TableFunctionResolver

org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.WindowingTableFunctionResolver

Enclosing class:

WindowingTableFunction

public static class WindowingTableFunction.WindowingTableFunctionResolver
extends TableFunctionResolver

Constructor Summary

Constructors

Constructor and Description
WindowingTableFunctionResolver()

Method Summary

Modifier and Type	Method and Description
boolean	carryForwardNames()
protected TableFunctionEvaluator	createEvaluator(PTFDesc ptfDesc, PartitionedTableFunctionDef tDef)
ArrayList<String>	getOutputColumnNames()
StructObjectInspector	getWdwProcessingOutputOI()
void	initializeOutputOI() This method is invoked during runtime(during deserialization of theQueryDef).
void	setupOutputOI()
void	setWdwProcessingOutputOI(StructObjectInspector wdwProcessingOutputOI)
boolean	transformsRawInput()

Methods inherited from class org.apache.hadoop.hive.ql.udf.ptf.TableFunctionResolver

getEvaluator, getPtfDesc, getRawInputColumnNames, getReferencedColumns, initialize, initialize, initializeRawInputOI, setOutputOI, setRawInputOI, setupRawInputOI

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WindowingTableFunctionResolver

public WindowingTableFunctionResolver()

Method Detail

getWdwProcessingOutputOI

public StructObjectInspector getWdwProcessingOutputOI()

setWdwProcessingOutputOI

public void setWdwProcessingOutputOI(StructObjectInspector wdwProcessingOutputOI)

createEvaluator

protected TableFunctionEvaluator createEvaluator(PTFDesc ptfDesc,
                                                 PartitionedTableFunctionDef tDef)

Specified by:

createEvaluator in class TableFunctionResolver

setupOutputOI

public void setupOutputOI()
                   throws SemanticException

Specified by:

setupOutputOI in class TableFunctionResolver

Throws:

SemanticException

initializeOutputOI

public void initializeOutputOI()
                        throws HiveException

Description copied from class: TableFunctionResolver

This method is invoked during runtime(during deserialization of theQueryDef). At this point the TableFunction can assume that the Expression Nodes exist for all the Def (ArgDef, ColumnDef, WindowDef..). It is the responsibility of the TableFunction to construct the evaluators and setup the OI.

Specified by:

initializeOutputOI in class TableFunctionResolver

Throws:

HiveException

transformsRawInput

public boolean transformsRawInput()

Specified by:

transformsRawInput in class TableFunctionResolver

carryForwardNames

public boolean carryForwardNames()

Overrides:

carryForwardNames in class TableFunctionResolver

getOutputColumnNames

public ArrayList<String> getOutputColumnNames()

Specified by:

getOutputColumnNames in class TableFunctionResolver