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.DoubleValueBoundaryScanner
static class	WindowingTableFunction.HiveDecimalValueBoundaryScanner
static class	WindowingTableFunction.LongValueBoundaryScanner
static class	WindowingTableFunction.SameList<E>
static class	WindowingTableFunction.StringValueBoundaryScanner
class	WindowingTableFunction.WindowingIterator
static class	WindowingTableFunction.WindowingTableFunctionResolver

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	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

Methods

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.apache.commons.logging.Log 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