org.apache.hadoop.hive.ql.plan

Class PTFDeserializer

java.lang.Object

org.apache.hadoop.hive.ql.plan.PTFDeserializer

public class PTFDeserializer
extends Object

Constructor Summary

Constructors

Constructor and Description
PTFDeserializer(PTFDesc ptfDesc, StructObjectInspector inputOI, org.apache.hadoop.conf.Configuration hConf)

Method Summary

Modifier and Type	Method and Description
static void	addOIPropertiestoSerDePropsMap(StructObjectInspector OI, Map<String,String> serdePropsMap)
static void	alterOutputOIForStreaming(PTFDesc ptfDesc)
protected void	initialize(PartitionedTableFunctionDef def)
protected void	initialize(PTFExpressionDef eDef, ShapeDetails inpShape)
protected void	initialize(PTFQueryInputDef def, StructObjectInspector OI)
protected void	initialize(ShapeDetails shp, StructObjectInspector OI)
protected void	initialize(WindowFrameDef winFrame, ShapeDetails inpShape)
void	initializePTFChain(PartitionedTableFunctionDef tblFnDef)
void	initializeWindowing(WindowTableFunctionDef def)

Methods inherited from class java.lang.Object

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

Constructor Detail

PTFDeserializer

public PTFDeserializer(PTFDesc ptfDesc,
                       StructObjectInspector inputOI,
                       org.apache.hadoop.conf.Configuration hConf)

Method Detail

initializePTFChain

public void initializePTFChain(PartitionedTableFunctionDef tblFnDef)
                        throws HiveException

Throws:

HiveException

initializeWindowing

public void initializeWindowing(WindowTableFunctionDef def)
                         throws HiveException

Throws:

HiveException

initialize

protected void initialize(PTFQueryInputDef def,
                          StructObjectInspector OI)
                   throws HiveException

Throws:

HiveException

initialize

protected void initialize(PartitionedTableFunctionDef def)
                   throws HiveException

Throws:

HiveException

initialize

protected void initialize(WindowFrameDef winFrame,
                          ShapeDetails inpShape)
                   throws HiveException

Throws:

HiveException

initialize

protected void initialize(PTFExpressionDef eDef,
                          ShapeDetails inpShape)
                   throws HiveException

Throws:

HiveException

initialize

protected void initialize(ShapeDetails shp,
                          StructObjectInspector OI)
                   throws HiveException

Throws:

HiveException

addOIPropertiestoSerDePropsMap

public static void addOIPropertiestoSerDePropsMap(StructObjectInspector OI,
                                                  Map<String,String> serdePropsMap)

alterOutputOIForStreaming

public static void alterOutputOIForStreaming(PTFDesc ptfDesc)