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

Class NoopStreaming

java.lang.Object

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

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

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

public class NoopStreaming
extends Noop

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NoopStreaming.NoopStreamingResolver

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.udf.ptf.Noop

Noop.NoopResolver

Field Summary

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

canAcceptInputAsStream, OI, outputPartition, ptfDesc, rawInputOI, tableDef

Method Summary

Methods

Modifier and Type	Method and Description
void	initializeStreaming(org.apache.hadoop.conf.Configuration cfg, StructObjectInspector inputOI, boolean isMapSide)
List<Object>	processRow(Object row)

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

execute, execute

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

_transformRawInput, canAcceptInputAsStream, canIterateOutput, close, finishPartition, getOutputOI, getQueryDef, getRawInputOI, getTableDef, isTransformsRawInput, iterator, setOutputOI, setQueryDef, setRawInputOI, setTableDef, setTransformsRawInput, startPartition, transformRawInput, transformRawInputIterator

Methods inherited from class java.lang.Object

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

Method Detail

initializeStreaming

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

Overrides:

initializeStreaming in class TableFunctionEvaluator

Throws:

HiveException

processRow

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

Overrides:

processRow in class TableFunctionEvaluator

Throws:

HiveException