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

Class NoopWithMapStreaming

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.NoopWithMap

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

public class NoopWithMapStreaming
extends NoopWithMap

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NoopWithMapStreaming.NoopWithMapStreamingResolver

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

NoopWithMap.NoopWithMapResolver

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

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.NoopWithMap

_transformRawInput

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

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