public class WindowingTableFunction extends TableFunctionEvaluator
Modifier and Type | Class and Description |
---|---|
static class |
WindowingTableFunction.DoubleValueBoundaryScanner |
static class |
WindowingTableFunction.LongValueBoundaryScanner |
static class |
WindowingTableFunction.SameList<E> |
static class |
WindowingTableFunction.StringValueBoundaryScanner |
static class |
WindowingTableFunction.WindowingTableFunctionResolver |
OI, outputPartition, ptfDesc, rawInputOI, tDef
Constructor and Description |
---|
WindowingTableFunction() |
Modifier and Type | Method and Description |
---|---|
void |
execute(PTFPartition.PTFPartitionIterator<java.lang.Object> pItr,
PTFPartition outP) |
_transformRawInput, execute, getOutputOI, getQueryDef, getRawInputOI, getTableDef, isTransformsRawInput, setOutputOI, setQueryDef, setRawInputOI, setTableDef, setTransformsRawInput, transformRawInput
public void execute(PTFPartition.PTFPartitionIterator<java.lang.Object> pItr, PTFPartition outP) throws HiveException
execute
in class TableFunctionEvaluator
HiveException
Copyright © 2012 The Apache Software Foundation