public class PTFDeserializer extends Object
Constructor and Description |
---|
PTFDeserializer(PTFDesc ptfDesc,
StructObjectInspector inputOI,
org.apache.hadoop.conf.Configuration hConf) |
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) |
public PTFDeserializer(PTFDesc ptfDesc, StructObjectInspector inputOI, org.apache.hadoop.conf.Configuration hConf)
public void initializePTFChain(PartitionedTableFunctionDef tblFnDef) throws HiveException
HiveException
public void initializeWindowing(WindowTableFunctionDef def) throws HiveException
HiveException
protected void initialize(PTFQueryInputDef def, StructObjectInspector OI) throws HiveException
HiveException
protected void initialize(PartitionedTableFunctionDef def) throws HiveException
HiveException
protected void initialize(WindowFrameDef winFrame, ShapeDetails inpShape) throws HiveException
HiveException
protected void initialize(PTFExpressionDef eDef, ShapeDetails inpShape) throws HiveException
HiveException
protected void initialize(ShapeDetails shp, StructObjectInspector OI) throws HiveException
HiveException
public static void addOIPropertiestoSerDePropsMap(StructObjectInspector OI, Map<String,String> serdePropsMap)
public static void alterOutputOIForStreaming(PTFDesc ptfDesc)
Copyright © 2019 The Apache Software Foundation. All rights reserved.