public class PTFTranslator
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
PTFTranslator.LeadLagInfo |
static class |
PTFTranslator.ValidateNoLeadLag |
Constructor and Description |
---|
PTFTranslator() |
Modifier and Type | Method and Description |
---|---|
protected static java.util.ArrayList<PTFInvocationSpec.OrderExpression> |
addPartitionExpressionsToOrderList(java.util.ArrayList<PTFInvocationSpec.PartitionExpression> partCols,
java.util.ArrayList<PTFInvocationSpec.OrderExpression> orderCols) |
PTFDesc.PTFExpressionDef |
buildExpressionDef(PTFDesc.ShapeDetails inpShape,
ASTNode arg) |
protected static RowResolver |
buildRowResolverForNoop(java.lang.String tabAlias,
StructObjectInspector rowObjectInspector,
RowResolver inputRowResolver) |
protected static RowResolver |
buildRowResolverForPTF(java.lang.String tbFnName,
java.lang.String tabAlias,
StructObjectInspector rowObjectInspector,
java.util.ArrayList<java.lang.String> outputColNames,
RowResolver inputRR) |
protected RowResolver |
buildRowResolverForWindowing(PTFDesc.WindowTableFunctionDef def) |
static java.util.ArrayList<PTFInvocationSpec> |
componentize(PTFInvocationSpec ptfInvocation) |
protected static SerDe |
createLazyBinarySerDe(Configuration cfg,
StructObjectInspector oi,
java.util.Map<java.lang.String,java.lang.String> serdePropsMap) |
static ASTNode |
getASTNode(ColumnInfo cInfo,
RowResolver rr) |
static StructObjectInspector |
getStandardStructOI(RowResolver rr)
For each column on the input RR, construct a StructField for it
OI is constructed using the list of input column names and
their corresponding OIs.
|
PTFDesc |
translate(PTFInvocationSpec qSpec,
SemanticAnalyzer semAly,
HiveConf hCfg,
RowResolver inputRR,
org.apache.hadoop.hive.ql.parse.UnparseTranslator unparseT) |
PTFDesc |
translate(WindowingSpec wdwSpec,
SemanticAnalyzer semAly,
HiveConf hCfg,
RowResolver inputRR,
org.apache.hadoop.hive.ql.parse.UnparseTranslator unparseT) |
protected static void |
validateComparable(ObjectInspector OI,
java.lang.String errMsg) |
static void |
validateNoLeadLagInValueBoundarySpec(ASTNode node) |
static void |
visit(java.lang.Object t,
org.antlr.runtime.tree.TreeWizard.ContextVisitor visitor) |
public PTFDesc translate(PTFInvocationSpec qSpec, SemanticAnalyzer semAly, HiveConf hCfg, RowResolver inputRR, org.apache.hadoop.hive.ql.parse.UnparseTranslator unparseT) throws SemanticException
SemanticException
public PTFDesc translate(WindowingSpec wdwSpec, SemanticAnalyzer semAly, HiveConf hCfg, RowResolver inputRR, org.apache.hadoop.hive.ql.parse.UnparseTranslator unparseT) throws SemanticException
SemanticException
protected static java.util.ArrayList<PTFInvocationSpec.OrderExpression> addPartitionExpressionsToOrderList(java.util.ArrayList<PTFInvocationSpec.PartitionExpression> partCols, java.util.ArrayList<PTFInvocationSpec.OrderExpression> orderCols) throws SemanticException
SemanticException
public PTFDesc.PTFExpressionDef buildExpressionDef(PTFDesc.ShapeDetails inpShape, ASTNode arg) throws HiveException
HiveException
protected static SerDe createLazyBinarySerDe(Configuration cfg, StructObjectInspector oi, java.util.Map<java.lang.String,java.lang.String> serdePropsMap) throws SerDeException
SerDeException
public static StructObjectInspector getStandardStructOI(RowResolver rr)
rr
- protected static void validateComparable(ObjectInspector OI, java.lang.String errMsg) throws SemanticException
SemanticException
protected static RowResolver buildRowResolverForPTF(java.lang.String tbFnName, java.lang.String tabAlias, StructObjectInspector rowObjectInspector, java.util.ArrayList<java.lang.String> outputColNames, RowResolver inputRR) throws SemanticException
SemanticException
protected RowResolver buildRowResolverForWindowing(PTFDesc.WindowTableFunctionDef def) throws SemanticException
SemanticException
protected static RowResolver buildRowResolverForNoop(java.lang.String tabAlias, StructObjectInspector rowObjectInspector, RowResolver inputRowResolver) throws SemanticException
SemanticException
public static ASTNode getASTNode(ColumnInfo cInfo, RowResolver rr) throws SemanticException
SemanticException
public static void visit(java.lang.Object t, org.antlr.runtime.tree.TreeWizard.ContextVisitor visitor)
public static java.util.ArrayList<PTFInvocationSpec> componentize(PTFInvocationSpec ptfInvocation) throws SemanticException
SemanticException
public static void validateNoLeadLagInValueBoundarySpec(ASTNode node) throws SemanticException
SemanticException
Copyright © 2012 The Apache Software Foundation