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

Class WindowingTableFunction

java.lang.Object

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

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

public class WindowingTableFunction
extends TableFunctionEvaluator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WindowingTableFunction.SameList<E>
class	WindowingTableFunction.WindowingIterator
static class	WindowingTableFunction.WindowingTableFunctionResolver

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hive.ql.udf.ptf.TableFunctionEvaluator

canAcceptInputAsStream, OI, outputPartition, ptfDesc, rawInputOI, tableDef

Constructor Summary

Constructors

Constructor and Description
WindowingTableFunction()

Method Summary

Modifier and Type	Method and Description
boolean	canIterateOutput()
void	execute(PTFPartition.PTFPartitionIterator<Object> pItr, PTFPartition outP)
List<Object>	finishPartition()
Map<String,org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.WindowingFunctionInfoHelper>	getWindowingFunctionHelpers()
void	initializeStreaming(org.apache.hadoop.conf.Configuration cfg, StructObjectInspector inputOI, boolean isMapSide)
Iterator<Object>	iterator(PTFPartition.PTFPartitionIterator<Object> pItr)
List<Object>	processRow(Object row)
protected void	setOutputOI(StructObjectInspector outputOI)
void	setWindowingFunctionHelpers(Map<String,org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.WindowingFunctionInfoHelper> windowingFunctionHelpers)
void	startPartition()

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

_transformRawInput, canAcceptInputAsStream, close, execute, getOutputOI, getQueryDef, getRawInputOI, getTableDef, isTransformsRawInput, setQueryDef, setRawInputOI, setTableDef, setTransformsRawInput, transformRawInput, transformRawInputIterator

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

WindowingTableFunction

public WindowingTableFunction()

Method Detail

getWindowingFunctionHelpers

public Map<String,org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.WindowingFunctionInfoHelper> getWindowingFunctionHelpers()

setWindowingFunctionHelpers

public void setWindowingFunctionHelpers(Map<String,org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.WindowingFunctionInfoHelper> windowingFunctionHelpers)

execute

public void execute(PTFPartition.PTFPartitionIterator<Object> pItr,
                    PTFPartition outP)
             throws HiveException

Specified by:

execute in class TableFunctionEvaluator

Throws:

HiveException

setOutputOI

protected void setOutputOI(StructObjectInspector outputOI)

Overrides:

setOutputOI in class TableFunctionEvaluator

initializeStreaming

public void initializeStreaming(org.apache.hadoop.conf.Configuration cfg,
                                StructObjectInspector inputOI,
                                boolean isMapSide)
                         throws HiveException

Overrides:

initializeStreaming in class TableFunctionEvaluator

Throws:

HiveException

startPartition

public void startPartition()
                    throws HiveException

Overrides:

startPartition in class TableFunctionEvaluator

Throws:

HiveException

processRow

public List<Object> processRow(Object row)
                        throws HiveException

Overrides:

processRow in class TableFunctionEvaluator

Throws:

HiveException

finishPartition

public List<Object> finishPartition()
                             throws HiveException

Overrides:

finishPartition in class TableFunctionEvaluator

Throws:

HiveException

canIterateOutput

public boolean canIterateOutput()

Overrides:

canIterateOutput in class TableFunctionEvaluator

iterator

public Iterator<Object> iterator(PTFPartition.PTFPartitionIterator<Object> pItr)
                          throws HiveException

Overrides:

iterator in class TableFunctionEvaluator

Throws:

HiveException