org.apache.hadoop.hive.ql.parse.QBParseInfo.getAllExprToColumnAlias()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(3.8k)|赞(0)|评价(0)|浏览(115)

本文整理了Java中org.apache.hadoop.hive.ql.parse.QBParseInfo.getAllExprToColumnAlias方法的一些代码示例,展示了QBParseInfo.getAllExprToColumnAlias的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QBParseInfo.getAllExprToColumnAlias方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.parse.QBParseInfo
类名称:QBParseInfo
方法名:getAllExprToColumnAlias

QBParseInfo.getAllExprToColumnAlias介绍

暂无

代码示例

代码示例来源:origin: apache/hive

Map<ASTNode, String> exprToAlias = qbPI.getAllExprToColumnAlias();

代码示例来源:origin: apache/drill

Map<ASTNode, String> exprToAlias = qbPI.getAllExprToColumnAlias();

代码示例来源:origin: apache/hive

Map<ASTNode, String> exprToColumnAlias = qb.getParseInfo().getAllExprToColumnAlias();
for (ASTNode astNode : exprToColumnAlias.keySet()) {
 if (inputRR.getExpression(astNode) != null) {

代码示例来源:origin: apache/drill

Map<ASTNode, String> exprToColumnAlias = qb.getParseInfo().getAllExprToColumnAlias();
for (ASTNode astNode : exprToColumnAlias.keySet()) {
 if (inputRR.getExpression(astNode) != null) {

代码示例来源:origin: com.facebook.presto.hive/hive-apache

Map<ASTNode, String> exprToAlias = qbPI.getAllExprToColumnAlias();

代码示例来源:origin: org.apache.lens/lens-cube

builder.append("\n limit: ").append(parseInfo.getDestLimit(clause));
if (parseInfo.getAllExprToColumnAlias() != null && !parseInfo.getAllExprToColumnAlias().isEmpty()) {
 builder.append("\n exprToColumnAlias:");
 for (Map.Entry<ASTNode, String> entry : parseInfo.getAllExprToColumnAlias().entrySet()) {
  builder.append("\n\t expr: ").append(entry.getKey().dump()).append(" ColumnAlias: ").append(entry.getValue());

代码示例来源:origin: apache/lens

builder.append("\n limit: ").append(parseInfo.getDestLimit(clause));
if (parseInfo.getAllExprToColumnAlias() != null && !parseInfo.getAllExprToColumnAlias().isEmpty()) {
 builder.append("\n exprToColumnAlias:");
 for (Map.Entry<ASTNode, String> entry : parseInfo.getAllExprToColumnAlias().entrySet()) {
  builder.append("\n\t expr: ").append(entry.getKey().dump()).append(" ColumnAlias: ").append(entry.getValue());

代码示例来源:origin: com.facebook.presto.hive/hive-apache

@SuppressWarnings("nls")
private Operator genHavingPlan(String dest, QB qb, Operator input,
  Map<String, Operator> aliasToOpInfo)
  throws SemanticException {
 ASTNode havingExpr = qb.getParseInfo().getHavingForClause(dest);
 OpParseContext inputCtx = opParseCtx.get(input);
 RowResolver inputRR = inputCtx.getRowResolver();
 Map<ASTNode, String> exprToColumnAlias = qb.getParseInfo().getAllExprToColumnAlias();
 for (ASTNode astNode : exprToColumnAlias.keySet()) {
  if (inputRR.getExpression(astNode) != null) {
   inputRR.put("", exprToColumnAlias.get(astNode), inputRR.getExpression(astNode));
  }
 }
 ASTNode condn = (ASTNode) havingExpr.getChild(0);
 /*
  * Now a having clause can contain a SubQuery predicate;
  * so we invoke genFilterPlan to handle SubQuery algebraic transformation,
  * just as is done for SubQuery predicates appearing in the Where Clause.
  */
 Operator output = genFilterPlan(condn, qb, input, aliasToOpInfo, true);
 output = putOpInsertMap(output, inputRR);
 return output;
}

代码示例来源:origin: org.apache.hadoop.hive/hive-exec

@SuppressWarnings("nls")
private Operator genHavingPlan(String dest, QB qb, Operator input)
  throws SemanticException {
 ASTNode havingExpr = qb.getParseInfo().getHavingForClause(dest);
 OpParseContext inputCtx = opParseCtx.get(input);
 RowResolver inputRR = inputCtx.getRowResolver();
 Map<ASTNode, String> exprToColumnAlias = qb.getParseInfo().getAllExprToColumnAlias();
 for (ASTNode astNode : exprToColumnAlias.keySet()) {
  if (inputRR.getExpression(astNode) != null) {
   inputRR.put("", exprToColumnAlias.get(astNode), inputRR.getExpression(astNode));
  }
 }
 ASTNode condn = (ASTNode) havingExpr.getChild(0);
 Operator output = putOpInsertMap(OperatorFactory.getAndMakeChild(
   new FilterDesc(genExprNodeDesc(condn, inputRR), false), new RowSchema(
   inputRR.getColumnInfos()), input), inputRR);
 return output;
}

相关文章

微信公众号

最新文章

更多

QBParseInfo类方法