org.apache.calcite.rex.RexBuilder.addAggCall()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(81)

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

RexBuilder.addAggCall介绍

[英]Creates a reference to an aggregate call, checking for repeated calls.

Argument types help to optimize for repeated aggregates. For instance count(42) is equivalent to count().
[中]创建对聚合调用的引用，检查重复调用。
参数类型有助于优化重复聚合。例如，count（42）等同于count（）。

代码示例

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

rexBuilder.addAggCall(sumCall,
    nGroups,
    oldAggRel.indicator,
    ImmutableList.of(avgInputType));
final RexNode denominatorRef =
  rexBuilder.addAggCall(countCall,
    nGroups,
    oldAggRel.indicator,

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

rexBuilder.addAggCall(sumArgSquaredAggCall,
  nGroups,
  oldAggRel.indicator,
rexBuilder.addAggCall(sumArgAggCall,
  nGroups,
  oldAggRel.indicator,
rexBuilder.addAggCall(countArgAggCall,
  nGroups,
  oldAggRel.indicator,

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

rexBuilder.addAggCall(sumCall,
  nGroups,
  oldAggRel.indicator,

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

SqlTypeUtil.projectTypes(
    oldAggRel.getInput().getRowType(), oldCall.getArgList());
return rexBuilder.addAggCall(oldCall,
  nGroups,
  oldAggRel.indicator,

代码示例来源：origin: Qihoo360/Quicksql

private RexNode getSumAggregatedRexNodeWithBinding(Aggregate oldAggRel,
  AggregateCall oldCall,
  List<AggregateCall> newCalls,
  Map<AggregateCall, RexNode> aggCallMapping,
  RelDataType operandType,
  int argOrdinal,
  int filter) {
 RelOptCluster cluster = oldAggRel.getCluster();
 final AggregateCall sumArgSquaredAggCall =
   createAggregateCallWithBinding(cluster.getTypeFactory(),
     SqlStdOperatorTable.SUM, operandType, oldAggRel, oldCall, argOrdinal, filter);
 return cluster.getRexBuilder().addAggCall(sumArgSquaredAggCall,
   oldAggRel.getGroupCount(),
   oldAggRel.indicator,
   newCalls,
   aggCallMapping,
   ImmutableList.of(sumArgSquaredAggCall.getType()));
}

代码示例来源：origin: org.apache.calcite/calcite-core

private RexNode getSumAggregatedRexNodeWithBinding(Aggregate oldAggRel,
  AggregateCall oldCall,
  List<AggregateCall> newCalls,
  Map<AggregateCall, RexNode> aggCallMapping,
  RelDataType operandType,
  int argOrdinal,
  int filter) {
 RelOptCluster cluster = oldAggRel.getCluster();
 final AggregateCall sumArgSquaredAggCall =
   createAggregateCallWithBinding(cluster.getTypeFactory(),
     SqlStdOperatorTable.SUM, operandType, oldAggRel, oldCall, argOrdinal, filter);
 return cluster.getRexBuilder().addAggCall(sumArgSquaredAggCall,
   oldAggRel.getGroupCount(),
   oldAggRel.indicator,
   newCalls,
   aggCallMapping,
   ImmutableList.of(sumArgSquaredAggCall.getType()));
}

代码示例来源：origin: org.apache.calcite/calcite-core

private RexNode getSumAggregatedRexNode(Aggregate oldAggRel,
  AggregateCall oldCall,
  List<AggregateCall> newCalls,
  Map<AggregateCall, RexNode> aggCallMapping,
  RexBuilder rexBuilder,
  int argOrdinal,
  int filterArg) {
 final AggregateCall aggregateCall =
   AggregateCall.create(SqlStdOperatorTable.SUM,
     oldCall.isDistinct(),
     oldCall.isApproximate(),
     ImmutableIntList.of(argOrdinal),
     filterArg,
     oldCall.collation,
     oldAggRel.getGroupCount(),
     oldAggRel.getInput(),
     null,
     null);
 return rexBuilder.addAggCall(aggregateCall,
   oldAggRel.getGroupCount(),
   oldAggRel.indicator,
   newCalls,
   aggCallMapping,
   ImmutableList.of(aggregateCall.getType()));
}

代码示例来源：origin: Qihoo360/Quicksql

private RexNode getSumAggregatedRexNode(Aggregate oldAggRel,
  AggregateCall oldCall,
  List<AggregateCall> newCalls,
  Map<AggregateCall, RexNode> aggCallMapping,
  RexBuilder rexBuilder,
  int argOrdinal,
  int filterArg) {
 final AggregateCall aggregateCall =
   AggregateCall.create(SqlStdOperatorTable.SUM,
     oldCall.isDistinct(),
     oldCall.isApproximate(),
     ImmutableIntList.of(argOrdinal),
     filterArg,
     oldAggRel.getGroupCount(),
     oldAggRel.getInput(),
     null,
     null);
 return rexBuilder.addAggCall(aggregateCall,
   oldAggRel.getGroupCount(),
   oldAggRel.indicator,
   newCalls,
   aggCallMapping,
   ImmutableList.of(aggregateCall.getType()));
}

代码示例来源：origin: Qihoo360/Quicksql

aggregatingSelectScope.resolved.get();
RexNode rex =
  rexBuilder.addAggCall(
    aggCall,
    groupExprs.size(),

代码示例来源：origin: org.apache.kylin/atopcalcite

aggregatingSelectScope.resolved.get();
RexNode rex =
  rexBuilder.addAggCall(
    aggCall,
    groupExprs.size(),

代码示例来源：origin: org.apache.calcite/calcite-core

private RexNode getRegrCountRexNode(Aggregate oldAggRel,
  AggregateCall oldCall,
  List<AggregateCall> newCalls,
  Map<AggregateCall, RexNode> aggCallMapping,
  ImmutableIntList argOrdinals,
  ImmutableList<RelDataType> operandTypes,
  int filterArg) {
 final AggregateCall countArgAggCall =
   AggregateCall.create(SqlStdOperatorTable.REGR_COUNT,
     oldCall.isDistinct(),
     oldCall.isApproximate(),
     argOrdinals,
     filterArg,
     oldCall.collation,
     oldAggRel.getGroupCount(),
     oldAggRel,
     null,
     null);
 return oldAggRel.getCluster().getRexBuilder().addAggCall(countArgAggCall,
   oldAggRel.getGroupCount(),
   oldAggRel.indicator,
   newCalls,
   aggCallMapping,
   operandTypes);
}

代码示例来源：origin: Qihoo360/Quicksql

private RexNode getRegrCountRexNode(Aggregate oldAggRel,
  AggregateCall oldCall,
  List<AggregateCall> newCalls,
  Map<AggregateCall, RexNode> aggCallMapping,
  ImmutableIntList argOrdinals,
  ImmutableList<RelDataType> operandTypes,
  int filterArg) {
 final AggregateCall countArgAggCall =
   AggregateCall.create(SqlStdOperatorTable.REGR_COUNT,
     oldCall.isDistinct(),
     oldCall.isApproximate(),
     argOrdinals,
     filterArg,
     oldAggRel.getGroupCount(),
     oldAggRel,
     null,
     null);
 return oldAggRel.getCluster().getRexBuilder().addAggCall(countArgAggCall,
   oldAggRel.getGroupCount(),
   oldAggRel.indicator,
   newCalls,
   aggCallMapping,
   operandTypes);
}

代码示例来源：origin: org.apache.flink/flink-table_2.10

aggregatingSelectScope.resolved.get();
RexNode rex =
  rexBuilder.addAggCall(
    aggCall,
    groupExprs.size(),

代码示例来源：origin: Qihoo360/Quicksql

rexBuilder.addAggCall(sumZeroCall,
  nGroups,
  oldAggRel.indicator,
rexBuilder.addAggCall(countCall,
  nGroups,
  oldAggRel.indicator,

代码示例来源：origin: org.apache.calcite/calcite-core

rexBuilder.addAggCall(sumZeroCall,
  nGroups,
  oldAggRel.indicator,
rexBuilder.addAggCall(countCall,
  nGroups,
  oldAggRel.indicator,

代码示例来源：origin: org.apache.calcite/calcite-core

rexBuilder.addAggCall(sumCall,
    nGroups,
    oldAggRel.indicator,
    ImmutableList.of(avgInputType));
final RexNode denominatorRef =
  rexBuilder.addAggCall(countCall,
    nGroups,
    oldAggRel.indicator,

代码示例来源：origin: org.apache.calcite/calcite-core

SqlTypeUtil.projectTypes(
    oldAggRel.getInput().getRowType(), oldCall.getArgList());
return rexBuilder.addAggCall(oldCall,
  nGroups,
  oldAggRel.indicator,

代码示例来源：origin: Qihoo360/Quicksql

rexBuilder.addAggCall(sumCall,
    nGroups,
    oldAggRel.indicator,
    ImmutableList.of(avgInputType));
final RexNode denominatorRef =
  rexBuilder.addAggCall(countCall,
    nGroups,
    oldAggRel.indicator,

代码示例来源：origin: org.apache.drill.exec/drill-java-exec

rexBuilder.addAggCall(
  sumZeroCall,
  nGroups,
rexBuilder.addAggCall(
  countCall,
  nGroups,

代码示例来源：origin: org.apache.drill.exec/drill-java-exec

oldAggregateCall.getName());
oldAggRel.getCluster().getRexBuilder()
  .addAggCall(sumZeroCall,
    oldAggRel.getGroupCount(),
    oldAggRel.indicator,

内容来源于网络，如有侵权，请联系作者删除！

RexBuilder

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    RexBuilder类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com