org.apache.calcite.rel.core.Aggregate.getGroupSet()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(9.9k)|赞(0)|评价(0)|浏览(112)

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

Aggregate.getGroupSet介绍

[英]Returns a bit set of the grouping fields.
[中]返回分组字段的位集。

代码示例

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

/**
 * Do a shallow clone of oldAggRel and update aggCalls. Could be refactored
 * into Aggregate and subclasses - but it's only needed for some
 * subclasses.
 *
 * @param relBuilder Builder of relational expressions; at the top of its
 *                   stack is its input
 * @param oldAggregate LogicalAggregate to clone.
 * @param newCalls  New list of AggregateCalls
 */
protected void newAggregateRel(RelBuilder relBuilder,
  Aggregate oldAggregate, List<AggregateCall> newCalls) {
 relBuilder.aggregate(
   relBuilder.groupKey(oldAggregate.getGroupSet(),
     oldAggregate.getGroupSets()),
   newCalls);
}

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

private static boolean isEmptyGrpAggr(RelNode gbNode) {
 // Verify if both groupset and aggrfunction are empty)
 Aggregate aggrnode = (Aggregate) gbNode;
 if (aggrnode.getGroupSet().isEmpty() && aggrnode.getAggCallList().isEmpty()) {
  return true;
 }
 return false;
}

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

private static boolean isEmptyGrpAggr(RelNode gbNode) {
 // Verify if both groupset and aggrfunction are empty)
 Aggregate aggrnode = (Aggregate) gbNode;
 if (aggrnode.getGroupSet().isEmpty() && aggrnode.getAggCallList().isEmpty()) {
  return true;
 }
 return false;
}

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

private ImmutableBitSet generateNewGroupset(Aggregate aggregate, ImmutableBitSet fieldsUsed) {
 ImmutableBitSet originalGroupSet = aggregate.getGroupSet();
  if (aggregate.getGroupSet().contains(key)) {
   groupByUniqueKey = key;
   break;
 ImmutableBitSet nonKeyColumns = aggregate.getGroupSet().except(groupByUniqueKey);
 ImmutableBitSet columnsToRemove = nonKeyColumns.except(fieldsUsed);
 ImmutableBitSet newGroupSet = aggregate.getGroupSet().except(columnsToRemove);

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

public void handle(Filter filter) {
 RelNode child = filter.getInput();
 if (child instanceof Aggregate && !((Aggregate) child).getGroupSet().isEmpty()) {
  ASTConverter.this.having = filter;
 } else {
  ASTConverter.this.where = filter;
 }
}

代码示例来源：origin: apache/incubator-druid

aggregate.getInput(),
aggregate.indicator,
aggregate.getGroupSet(),
aggregate.getGroupSets(),
newAggregateCalls

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

public void handle(Filter filter) {
 RelNode child = filter.getInput();
 if (child instanceof Aggregate && !((Aggregate) child).getGroupSet().isEmpty()) {
  ASTConverter.this.having = filter;
 } else {
  ASTConverter.this.where = filter;
 }
}

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

private static boolean validGBParent(RelNode gbNode, RelNode parent) {
 boolean validParent = true;
 // TOODO: Verify GB having is not a seperate filter (if so we shouldn't
 // introduce derived table)
 if (parent instanceof Join || parent instanceof SetOp
   || parent instanceof Aggregate
   || (parent instanceof Filter && ((Aggregate) gbNode).getGroupSet().isEmpty())) {
  validParent = false;
 }
 if (parent instanceof Project) {
  for (RexNode child : parent.getChildExps()) {
   if (child instanceof RexOver || child instanceof RexWinAggCall) {
    // Hive can't handle select rank() over(order by sum(c1)/sum(c2)) from t1 group by c3
    // but can handle    select rank() over (order by c4) from
    // (select sum(c1)/sum(c2)  as c4 from t1 group by c3) t2;
    // so introduce a project on top of this gby.
    return false;
   }
  }
 }
 return validParent;
}

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

private static boolean validGBParent(RelNode gbNode, RelNode parent) {
 boolean validParent = true;
 // TOODO: Verify GB having is not a seperate filter (if so we shouldn't
 // introduce derived table)
 if (parent instanceof Join || parent instanceof SetOp
   || parent instanceof Aggregate
   || (parent instanceof Filter && ((Aggregate) gbNode).getGroupSet().isEmpty())) {
  validParent = false;
 }
 if (parent instanceof Project) {
  for (RexNode child : parent.getChildExps()) {
   if (child instanceof RexOver || child instanceof RexWinAggCall) {
    // Hive can't handle select rank() over(order by sum(c1)/sum(c2)) from t1 group by c3
    // but can handle    select rank() over (order by c4) from
    // (select sum(c1)/sum(c2)  as c4 from t1 group by c3) t2;
    // so introduce a project on top of this gby.
    return false;
   }
  }
 }
 return validParent;
}

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

private boolean isAggWithConstantGbyKeys(final Aggregate aggregate, RelOptRuleCall call) {
 final RexBuilder rexBuilder = aggregate.getCluster().getRexBuilder();
 final RelMetadataQuery mq = call.getMetadataQuery();
 final RelOptPredicateList predicates =
   mq.getPulledUpPredicates(aggregate.getInput());
 if (predicates == null) {
  return false;
 }
 final NavigableMap<Integer, RexNode> map = new TreeMap<>();
 for (int key : aggregate.getGroupSet()) {
  final RexInputRef ref =
    rexBuilder.makeInputRef(aggregate.getInput(), key);
  if (predicates.constantMap.containsKey(ref)) {
   map.put(key, predicates.constantMap.get(ref));
  }
 }
 // None of the group expressions are constant. Nothing to do.
 if (map.isEmpty()) {
  return false;
 }
 final int groupCount = aggregate.getGroupCount();
 if (groupCount == map.size()) {
  return true;
 }
 return false;
}

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

public RelNode align(Aggregate rel, List<RelFieldCollation> collations) {
 // 1) We extract the group by positions that are part of the collations and
 // sort them so they respect it
 LinkedHashSet<Integer> aggregateColumnsOrder = new LinkedHashSet<>();
 ImmutableList.Builder<RelFieldCollation> propagateCollations = ImmutableList.builder();
 if (rel.getGroupType() == Group.SIMPLE && !collations.isEmpty()) {
  for (RelFieldCollation c : collations) {
   if (c.getFieldIndex() < rel.getGroupCount()) {
    // Group column found
    if (aggregateColumnsOrder.add(c.getFieldIndex())) {
     propagateCollations.add(c.copy(rel.getGroupSet().nth(c.getFieldIndex())));
    }
   }
  }
 }
 for (int i = 0; i < rel.getGroupCount(); i++) {
  if (!aggregateColumnsOrder.contains(i)) {
   // Not included in the input collations, but can be propagated as this Aggregate
   // will enforce it
   propagateCollations.add(new RelFieldCollation(rel.getGroupSet().nth(i)));
  }
 }
 // 2) We propagate
 final RelNode child = dispatchAlign(rel.getInput(), propagateCollations.build());
 // 3) We annotate the Aggregate operator with this info
 final HiveAggregate newAggregate = (HiveAggregate) rel.copy(rel.getTraitSet(),
     ImmutableList.of(child));
 newAggregate.setAggregateColumnsOrder(aggregateColumnsOrder);
 return newAggregate;
}

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

if ((!singleAggregate.getGroupSet().isEmpty())
    || (singleAggregate.getAggCallList().size() != 1)
    || !(singleAggregate.getAggCallList().get(0).getAggregation()
if (!aggregate.getGroupSet().isEmpty()) {
 return;

代码示例来源：origin: apache/incubator-druid

int outputNameCounter = 0;
for (int i : aggregate.getGroupSet()) {

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

Lists.newArrayList(aggregate.getAggCallList());
rewriteAggCalls(newAggCalls, argList, sourceOf);
final int cardinality = aggregate.getGroupSet().cardinality();
return aggregate.copy(aggregate.getTraitSet(), distinct,
  aggregate.indicator, ImmutableBitSet.range(cardinality), null,

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

public RelNode align(Aggregate rel, List<RelFieldCollation> collations) {
 // 1) We extract the group by positions that are part of the collations and
 // sort them so they respect it
 LinkedHashSet<Integer> aggregateColumnsOrder = new LinkedHashSet<>();
 ImmutableList.Builder<RelFieldCollation> propagateCollations = ImmutableList.builder();
 if (!rel.indicator && !collations.isEmpty()) {
  for (RelFieldCollation c : collations) {
   if (c.getFieldIndex() < rel.getGroupCount()) {
    // Group column found
    if (aggregateColumnsOrder.add(c.getFieldIndex())) {
     propagateCollations.add(c.copy(rel.getGroupSet().nth(c.getFieldIndex())));
    }
   }
  }
 }
 for (int i = 0; i < rel.getGroupCount(); i++) {
  if (!aggregateColumnsOrder.contains(i)) {
   // Not included in the input collations, but can be propagated as this Aggregate
   // will enforce it
   propagateCollations.add(new RelFieldCollation(rel.getGroupSet().nth(i)));
  }
 }
 // 2) We propagate
 final RelNode child = dispatchAlign(rel.getInput(), propagateCollations.build());
 // 3) We annotate the Aggregate operator with this info
 final HiveAggregate newAggregate = (HiveAggregate) rel.copy(rel.getTraitSet(),
     ImmutableList.of(child));
 newAggregate.setAggregateColumnsOrder(aggregateColumnsOrder);
 return newAggregate;
}

代码示例来源：origin: apache/incubator-druid

cost += COST_PER_COLUMN * partialQuery.getAggregate().getGroupSet().size();
cost += COST_PER_COLUMN * partialQuery.getAggregate().getAggCallList().size();

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

final RexBuilder rexBuilder = agg.getCluster().getRexBuilder();
ImmutableBitSet groupKeys = agg.getGroupSet();
Mapping m = Mappings.create(MappingType.PARTIAL_FUNCTION,
  input.getRowType().getFieldCount(), agg.getRowType().getFieldCount());

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

@Override public void onMatch(RelOptRuleCall call) {
  final Aggregate topAggregate = call.rel(0);
  final Join join = call.rel(1);
  final RelNode left = call.rel(2);
  final Aggregate aggregate = call.rel(3);
  // Gather columns used by aggregate operator
  final ImmutableBitSet.Builder topRefs = ImmutableBitSet.builder();
  topRefs.addAll(topAggregate.getGroupSet());
  for (AggregateCall aggCall : topAggregate.getAggCallList()) {
   topRefs.addAll(aggCall.getArgList());
   if (aggCall.filterArg != -1) {
    topRefs.set(aggCall.filterArg);
   }
  }
  perform(call, topRefs.build(), topAggregate, join, left, aggregate);
 }
}

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

final RelBuilder relBuilder = call.builder();
RelNode newRightInput = relBuilder.project(relBuilder.push(rightAggregate.getInput()).
  fields(rightAggregate.getGroupSet().asList())).build();
RelNode newSemiJoin = call.builder().push(left).push(newRightInput)
  .semiJoin(semijoin.getCondition()).build();

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

Schema(Schema src, Aggregate gBy) {
 for (int i : gBy.getGroupSet()) {
  ColumnInfo cI = src.get(i);
  add(cI);
 }
 List<AggregateCall> aggs = gBy.getAggCallList();
 for (AggregateCall agg : aggs) {
  if (agg.getAggregation() == HiveGroupingID.INSTANCE) {
   add(new ColumnInfo(null,VirtualColumn.GROUPINGID.getName()));
   continue;
  }
  int argCount = agg.getArgList().size();
  ASTBuilder b = agg.isDistinct() ? ASTBuilder.construct(HiveParser.TOK_FUNCTIONDI,
    "TOK_FUNCTIONDI") : argCount == 0 ? ASTBuilder.construct(HiveParser.TOK_FUNCTIONSTAR,
    "TOK_FUNCTIONSTAR") : ASTBuilder.construct(HiveParser.TOK_FUNCTION, "TOK_FUNCTION");
  b.add(HiveParser.Identifier, agg.getAggregation().getName());
  for (int i : agg.getArgList()) {
   RexInputRef iRef = new RexInputRef(i, gBy.getCluster().getTypeFactory()
     .createSqlType(SqlTypeName.ANY));
   b.add(iRef.accept(new RexVisitor(src, false, gBy.getCluster().getRexBuilder())));
  }
  add(new ColumnInfo(null, b.node()));
 }
}

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

Aggregate

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com