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

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

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

QBParseInfo.getDestToGroupBy介绍

暂无

代码示例

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

private RelNode genGBHavingLogicalPlan(QB qb, RelNode srcRel, Map<String, RelNode> aliasToRel)
  throws SemanticException {
 RelNode gbFilter = null;
 QBParseInfo qbp = getQBParseInfo(qb);
 String destClauseName = qbp.getClauseNames().iterator().next();
 ASTNode havingClause = qbp.getHavingForClause(qbp.getClauseNames().iterator().next());
 if (havingClause != null) {
  if (!(srcRel instanceof HiveAggregate)) {
   // ill-formed query like select * from t1 having c1 > 0;
   throw new CalciteSemanticException("Having clause without any group-by.",
     UnsupportedFeature.Having_clause_without_any_groupby);
  }
  ASTNode targetNode = (ASTNode) havingClause.getChild(0);
  validateNoHavingReferenceToAlias(qb, targetNode);
  if (!qbp.getDestToGroupBy().isEmpty()) {
   final boolean cubeRollupGrpSetPresent = (!qbp.getDestRollups().isEmpty()
       || !qbp.getDestGroupingSets().isEmpty() || !qbp.getDestCubes().isEmpty());
   // Special handling of grouping function
   targetNode = rewriteGroupingFunctionAST(getGroupByForClause(qbp, destClauseName), targetNode,
     !cubeRollupGrpSetPresent);
  }
  gbFilter = genFilterRelNode(qb, targetNode, srcRel, aliasToRel, null, null, true);
 }
 return gbFilter;
}

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

private RelNode genGBHavingLogicalPlan(QB qb, RelNode srcRel, Map<String, RelNode> aliasToRel)
  throws SemanticException {
 RelNode gbFilter = null;
 QBParseInfo qbp = getQBParseInfo(qb);
 String destClauseName = qbp.getClauseNames().iterator().next();
 ASTNode havingClause = qbp.getHavingForClause(qbp.getClauseNames().iterator().next());
 if (havingClause != null) {
  if (!(srcRel instanceof HiveAggregate)) {
   // ill-formed query like select * from t1 having c1 > 0;
   throw new CalciteSemanticException("Having clause without any group-by.",
     UnsupportedFeature.Having_clause_without_any_groupby);
  }
  ASTNode targetNode = (ASTNode) havingClause.getChild(0);
  validateNoHavingReferenceToAlias(qb, targetNode);
  if (!qbp.getDestToGroupBy().isEmpty()) {
   final boolean cubeRollupGrpSetPresent = (!qbp.getDestRollups().isEmpty()
       || !qbp.getDestGroupingSets().isEmpty() || !qbp.getDestCubes().isEmpty());
   // Special handling of grouping function
   targetNode = rewriteGroupingFunctionAST(getGroupByForClause(qbp, destClauseName), targetNode,
     !cubeRollupGrpSetPresent);
  }
  gbFilter = genFilterRelNode(qb, targetNode, srcRel, aliasToRel, null, null, true);
 }
 return gbFilter;
}

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

|| !qbp.getDestGroupingSets().isEmpty() || !qbp.getDestCubes().isEmpty());
for (WindowExpressionSpec wExprSpec : windowExpressions) {
 if (!qbp.getDestToGroupBy().isEmpty()) {

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

if (!qbp.getDestToGroupBy().isEmpty()) {
 throw new SemanticException(ErrorMsg.UDTF_NO_GROUP_BY.getMsg());

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

|| !qbp.getDestGroupingSets().isEmpty() || !qbp.getDestCubes().isEmpty());
for (WindowExpressionSpec wExprSpec : windowExpressions) {
 if (!qbp.getDestToGroupBy().isEmpty()) {

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

if (!qbp.getDestToGroupBy().isEmpty()) {
 throw new SemanticException(ErrorMsg.UDTF_NO_GROUP_BY.getMsg());

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

if (!isCBOExecuted() && !qb.getParseInfo().getDestToGroupBy().isEmpty()) {

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

if (!isCBOExecuted() && !qb.getParseInfo().getDestToGroupBy().isEmpty()) {

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

if (!qbp.getDestToGroupBy().isEmpty()) {
 throw new SemanticException(ErrorMsg.UDTF_NO_GROUP_BY.getMsg());

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

if (!qbp.getDestToGroupBy().isEmpty()) {
 throw new SemanticException(ErrorMsg.UDTF_NO_GROUP_BY.getMsg());

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

Operator genWindowingPlan(QB qb, WindowingSpec wSpec, Operator input) throws SemanticException {
 wSpec.validateAndMakeEffective();
 if (!isCBOExecuted() && !qb.getParseInfo().getDestToGroupBy().isEmpty()) {

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

Operator genWindowingPlan(QB qb, WindowingSpec wSpec, Operator input) throws SemanticException {
 wSpec.validateAndMakeEffective();
 if (!isCBOExecuted() && !qb.getParseInfo().getDestToGroupBy().isEmpty()) {

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

if (!isCBOExecuted() && !qb.getParseInfo().getDestToGroupBy().isEmpty()) {

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

if (!qbp.getDestToGroupBy().isEmpty()) {

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

if (!isCBOExecuted() && !qb.getParseInfo().getDestToGroupBy().isEmpty()) {

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

if (!qbp.getDestToGroupBy().isEmpty()) {

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

if (!qbp.getDestToGroupBy().isEmpty()) {
 throw new SemanticException(ErrorMsg.UDTF_NO_GROUP_BY.getMsg());

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

if (!qbp.getDestToGroupBy().isEmpty()) {
 throw new SemanticException(ErrorMsg.UDTF_NO_GROUP_BY.getMsg());

相关文章

微信公众号

最新文章

更多

QBParseInfo类方法