public class WindowingTableFunction extends TableFunctionEvaluator
Modifier and Type | Class and Description |
---|---|
static class |
WindowingTableFunction.SameList<E> |
class |
WindowingTableFunction.WindowingIterator |
static class |
WindowingTableFunction.WindowingTableFunctionResolver |
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
canAcceptInputAsStream, OI, outputPartition, ptfDesc, rawInputOI, tableDef
Constructor and Description |
---|
WindowingTableFunction() |
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() |
_transformRawInput, canAcceptInputAsStream, close, execute, getOutputOI, getQueryDef, getRawInputOI, getTableDef, isTransformsRawInput, setQueryDef, setRawInputOI, setTableDef, setTransformsRawInput, transformRawInput, transformRawInputIterator
public Map<String,org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.WindowingFunctionInfoHelper> getWindowingFunctionHelpers()
public void setWindowingFunctionHelpers(Map<String,org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.WindowingFunctionInfoHelper> windowingFunctionHelpers)
public void execute(PTFPartition.PTFPartitionIterator<Object> pItr, PTFPartition outP) throws HiveException
execute
in class TableFunctionEvaluator
HiveException
protected void setOutputOI(StructObjectInspector outputOI)
setOutputOI
in class TableFunctionEvaluator
public void initializeStreaming(org.apache.hadoop.conf.Configuration cfg, StructObjectInspector inputOI, boolean isMapSide) throws HiveException
initializeStreaming
in class TableFunctionEvaluator
HiveException
public void startPartition() throws HiveException
startPartition
in class TableFunctionEvaluator
HiveException
public List<Object> processRow(Object row) throws HiveException
processRow
in class TableFunctionEvaluator
HiveException
public List<Object> finishPartition() throws HiveException
finishPartition
in class TableFunctionEvaluator
HiveException
public boolean canIterateOutput()
canIterateOutput
in class TableFunctionEvaluator
public Iterator<Object> iterator(PTFPartition.PTFPartitionIterator<Object> pItr) throws HiveException
iterator
in class TableFunctionEvaluator
HiveException
Copyright © 2019 The Apache Software Foundation. All rights reserved.