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

x33g5p2x  于2022-01-26 转载在 其他  
字(11.7k)|赞(0)|评价(0)|浏览(179)

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

Project.getCluster介绍

暂无

代码示例

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

private static RexCall adjustOBSchema(RexCall obyExpr, Project obChild,
    List<FieldSchema> resultSchema) {
 int a = -1;
 List<RexNode> operands = new ArrayList<>();
 for (int k = 0; k < obyExpr.operands.size(); k++) {
  RexNode rn = obyExpr.operands.get(k);
  for (int j = 0; j < resultSchema.size(); j++) {
   if( obChild.getChildExps().get(j).toString().equals(rn.toString())) {
    a = j;
    break;
   }
  }
  if (a != -1) {
   operands.add(new RexInputRef(a, rn.getType()));
  } else {
   if (rn instanceof RexCall) {
    operands.add(adjustOBSchema((RexCall)rn, obChild, resultSchema));
   } else {
    operands.add(rn);
   }
  }
  a = -1;
 }
 return (RexCall) obChild.getCluster().getRexBuilder().makeCall(
     obyExpr.getType(), obyExpr.getOperator(), operands);
}

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

RelMetadataQuery mq = rel.getCluster().getMetadataQuery();
double numRows = mq.getRowCount(tScan);
List<ColStatistics> colStats = tScan.getColStat(BitSets

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

private static RexCall adjustOBSchema(RexCall obyExpr, Project obChild,
    List<FieldSchema> resultSchema) {
 int a = -1;
 List<RexNode> operands = new ArrayList<>();
 for (int k = 0; k < obyExpr.operands.size(); k++) {
  RexNode rn = obyExpr.operands.get(k);
  for (int j = 0; j < resultSchema.size(); j++) {
   if( obChild.getChildExps().get(j).toString().equals(rn.toString())) {
    a = j;
    break;
   }
  }
  if (a != -1) {
   operands.add(new RexInputRef(a, rn.getType()));
  } else {
   if (rn instanceof RexCall) {
    operands.add(adjustOBSchema((RexCall)rn, obChild, resultSchema));
   } else {
    operands.add(rn);
   }
  }
  a = -1;
 }
 return (RexCall) obChild.getCluster().getRexBuilder().makeCall(
     obyExpr.getType(), obyExpr.getOperator(), operands);
}

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

@Override
public void onMatch(RelOptRuleCall call) {
 final Project project = call.rel(0);
 boolean changed = false;
 final RexBuilder rexBuilder = project.getCluster().getRexBuilder();
 List<RexNode> newProjects = new ArrayList<>();
 for (RexNode oldNode : project.getProjects()) {
  RexNode newNode = analyzeRexNode(rexBuilder, oldNode);
  if (!newNode.toString().equals(oldNode.toString())) {
   changed = true;
   newProjects.add(newNode);
  } else {
   newProjects.add(oldNode);
  }
 }
 if (!changed) {
  return;
 }
 Project newProject = project.copy(project.getTraitSet(), project.getInput(), newProjects,
   project.getRowType(), project.getFlags());
 call.transformTo(newProject);
}

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

@Override
  public RelNode convert(RelNode rel) {
    final Project project = (Project) rel;
    final RelNode input = project.getInput();

    return new StreamsProjectRel(project.getCluster(),
                   project.getTraitSet().replace(StreamsLogicalConvention.INSTANCE),
                   convert(input, input.getTraitSet().replace(StreamsLogicalConvention.INSTANCE)), project.getProjects(),
                   project.getRowType());
  }
}

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

final RelOptCluster cluster = project.getCluster();
RelNode newProject = RelOptUtil.createProject(aggregate,
  ImmutableList.of(rexBuilder.makeCast(

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

final RexBuilder rexBuilder = project.getCluster().getRexBuilder();
RelOptPredicateList childInfo = mq.getPulledUpPredicates(child);

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

final RexBuilder rexBuilder = project.getCluster().getRexBuilder();
RelOptPredicateList childInfo = mq.getPulledUpPredicates(child);

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

@Override
public void onMatch(RelOptRuleCall call) {
 final Project project = call.rel(0);
 final RexBuilder rexBuilder = project.getCluster().getRexBuilder();
 List<RexNode> topProjExprs = project.getChildExps();
 Join join = call.rel(1);

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

project.getCluster().getPlanner().getContext().unwrap(SubqueryConf.class);
boolean isCorrScalarQuery = subqueryConfig.getCorrScalarRexSQWithAgg().contains(e.rel);
boolean hasNoWindowingAndNoGby =

代码示例来源：origin: dremio/dremio-oss

public static int numReducibleExprs(Project project) {
  final List<RexNode> expList = Lists.newArrayList(project.getProjects());
  final RelMetadataQuery mq = project.getCluster().getMetadataQuery();
  final RelOptPredicateList predicates = mq.getPulledUpPredicates(project.getInput());
  boolean reducible = reduceExpressions(project, expList, predicates);
  if (reducible) {
   int numReducible = 0;
   for (int i = 0; i < project.getProjects().size(); i++) {
    if (!project.getProjects().get(i).toString().equals(expList.get(i).toString())) {
     numReducible++;
    }
   }
   return numReducible;
  } else {
   return 0;
  }
 }
}

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

private static RexCall adjustOBSchema(RexCall obyExpr, Project obChild,
    List<FieldSchema> resultSchema) {
 int a = -1;
 List<RexNode> operands = new ArrayList<>();
 for (int k = 0; k < obyExpr.operands.size(); k++) {
  RexNode rn = obyExpr.operands.get(k);
  for (int j = 0; j < resultSchema.size(); j++) {
   if( obChild.getChildExps().get(j).toString().equals(rn.toString())) {
    a = j;
    break;
   }
  }
  if (a != -1) {
   operands.add(new RexInputRef(a, rn.getType()));
  } else {
   if (rn instanceof RexCall) {
    operands.add(adjustOBSchema((RexCall)rn, obChild, resultSchema));
   } else {
    operands.add(rn);
   }
  }
  a = -1;
 }
 return (RexCall) obChild.getCluster().getRexBuilder().makeCall(
     obyExpr.getType(), obyExpr.getOperator(), operands);
}

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

/**
 * Expression lineage from Project.
 */
public Set<RexNode> getExpressionLineage(Project rel,
  final RelMetadataQuery mq, RexNode outputExpression) {
 final RelNode input = rel.getInput();
 final RexBuilder rexBuilder = rel.getCluster().getRexBuilder();
 // Extract input fields referenced by expression
 final ImmutableBitSet inputFieldsUsed = extractInputRefs(outputExpression);
 // Infer column origin expressions for given references
 final Map<RexInputRef, Set<RexNode>> mapping = new LinkedHashMap<>();
 for (int idx : inputFieldsUsed) {
  final RexNode inputExpr = rel.getChildExps().get(idx);
  final Set<RexNode> originalExprs = mq.getExpressionLineage(input, inputExpr);
  if (originalExprs == null) {
   // Bail out
   return null;
  }
  final RexInputRef ref = RexInputRef.of(idx, rel.getRowType().getFieldList());
  mapping.put(ref, originalExprs);
 }
 // Return result
 return createAllPossibleExpressions(rexBuilder, outputExpression, mapping);
}

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

/**
 * Expression lineage from Project.
 */
public Set<RexNode> getExpressionLineage(Project rel,
  final RelMetadataQuery mq, RexNode outputExpression) {
 final RelNode input = rel.getInput();
 final RexBuilder rexBuilder = rel.getCluster().getRexBuilder();
 // Extract input fields referenced by expression
 final Set<RelDataTypeField> inputExtraFields = new LinkedHashSet<>();
 final RelOptUtil.InputFinder inputFinder = new RelOptUtil.InputFinder(inputExtraFields);
 outputExpression.accept(inputFinder);
 final ImmutableBitSet inputFieldsUsed = inputFinder.inputBitSet.build();
 // Infer column origin expressions for given references
 final Map<RexInputRef, Set<RexNode>> mapping = new LinkedHashMap<>();
 for (int idx : inputFieldsUsed) {
  final RexNode inputExpr = rel.getChildExps().get(idx);
  final Set<RexNode> originalExprs = mq.getExpressionLineage(input, inputExpr);
  if (originalExprs == null) {
   // Bail out
   return null;
  }
  final RexInputRef ref = RexInputRef.of(idx, rel.getRowType().getFieldList());
  mapping.put(ref, originalExprs);
 }
 // Return result
 return createAllPossibleExpressions(rexBuilder, outputExpression, mapping);
}

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

public Double getSelectivity(Project rel, RelMetadataQuery mq,
  RexNode predicate) {
 final List<RexNode> notPushable = new ArrayList<>();
 final List<RexNode> pushable = new ArrayList<>();
 RelOptUtil.splitFilters(
   ImmutableBitSet.range(rel.getRowType().getFieldCount()),
   predicate,
   pushable,
   notPushable);
 final RexBuilder rexBuilder = rel.getCluster().getRexBuilder();
 RexNode childPred =
   RexUtil.composeConjunction(rexBuilder, pushable, true);
 RexNode modifiedPred;
 if (childPred == null) {
  modifiedPred = null;
 } else {
  modifiedPred = RelOptUtil.pushPastProject(childPred, rel);
 }
 Double selectivity = mq.getSelectivity(rel.getInput(), modifiedPred);
 if (selectivity == null) {
  return null;
 } else {
  RexNode pred =
    RexUtil.composeConjunction(rexBuilder, notPushable, true);
  return selectivity * RelMdUtil.guessSelectivity(pred);
 }
}

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

public Double getSelectivity(Project rel, RelMetadataQuery mq,
  RexNode predicate) {
 final List<RexNode> notPushable = new ArrayList<>();
 final List<RexNode> pushable = new ArrayList<>();
 RelOptUtil.splitFilters(
   ImmutableBitSet.range(rel.getRowType().getFieldCount()),
   predicate,
   pushable,
   notPushable);
 final RexBuilder rexBuilder = rel.getCluster().getRexBuilder();
 RexNode childPred =
   RexUtil.composeConjunction(rexBuilder, pushable, true);
 RexNode modifiedPred;
 if (childPred == null) {
  modifiedPred = null;
 } else {
  modifiedPred = RelOptUtil.pushPastProject(childPred, rel);
 }
 Double selectivity = mq.getSelectivity(rel.getInput(), modifiedPred);
 if (selectivity == null) {
  return null;
 } else {
  RexNode pred =
    RexUtil.composeConjunction(rexBuilder, notPushable, true);
  return selectivity * RelMdUtil.guessSelectivity(pred);
 }
}

代码示例来源：origin: dremio/dremio-oss

@Override
 public void onMatch(RelOptRuleCall call) {
  final Project toTransform = call.rel(0);
  final RelNode input = toTransform.getInput();
  final RelTraitSet traits = toTransform.getTraitSet().plus(Rel.LOGICAL);
  final RelNode convertedInput = convert(input, input.getTraitSet().plus(Rel.LOGICAL).simplify());
  call.transformTo(new ProjectRel(toTransform.getCluster(), traits, convertedInput, toTransform.getProjects(), toTransform.getRowType()));
 }
}

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

@Override
 public void onMatch(RelOptRuleCall call) {
  final Project project = call.rel(0);
  final RelNode input = project.getInput();
  final RelTraitSet traits = project.getTraitSet().plus(DrillRel.DRILL_LOGICAL);
  final RelNode convertedInput = convert(input, input.getTraitSet().plus(DrillRel.DRILL_LOGICAL).simplify());
  call.transformTo(new DrillProjectRel(
    project.getCluster(), traits, convertedInput, project.getProjects(), project.getRowType()));
 }
}

代码示例来源：origin: dremio/dremio-oss

@Override
public void onMatch(RelOptRuleCall call) {
 final Project proj = call.rel(0);
 final ScanCrel scan = call.rel(1);
 ProjectPushInfo columnInfo = PrelUtil.getColumns(scan.getRowType(), proj.getProjects());
 // get TableBase, either wrapped in RelOptTable, or TranslatableTable. TableBase table = scan.getTable().unwrap(TableBase.class);
 if (columnInfo == null || columnInfo.isStarQuery()) {
  return;
 }
 ScanCrel newScan = scan.cloneWithProject(columnInfo.columns);
 List<RexNode> newProjects = Lists.newArrayList();
 for (RexNode n : proj.getChildExps()) {
  newProjects.add(n.accept(columnInfo.getInputRewriter()));
 }
 final RelBuilder relBuilder = relBuilderFactory.create(proj.getCluster(), null);
 relBuilder.push(newScan);
 relBuilder.project(newProjects, proj.getRowType().getFieldNames());
 final RelNode newProj = relBuilder.build();
 if (newProj instanceof Project
   && ProjectRemoveRule.isTrivial((Project) newProj)
   && newScan.getRowType().getFullTypeString().equals(newProj.getRowType().getFullTypeString())) {
   call.transformTo(newScan);
 } else {
  if(newScan.getProjectedColumns().equals(scan.getProjectedColumns())) {
   // no point in doing a pushdown that doesn't change anything.
   return;
  }
  call.transformTo(newProj);
 }
}

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

public void onMatch(RelOptRuleCall call) {
 Project project = call.rel(0);
 DruidQuery query = call.rel(1);
 final RelOptCluster cluster = project.getCluster();
 final RexBuilder rexBuilder = cluster.getRexBuilder();
 if (!DruidQuery.isValidSignature(query.signature() + 'o')) {
  return;
 }
 Pair<ImmutableMap<String, String>, Boolean> scanned = scanProject(query, project);
 // Only try to push down Project when there will be Post aggregators in result DruidQuery
 if (scanned.right) {
  Pair<Project, Project> splitProjectAggregate = splitProject(rexBuilder, query,
      project, scanned.left, cluster);
  Project inner = splitProjectAggregate.left;
  Project outer = splitProjectAggregate.right;
  DruidQuery newQuery = DruidQuery.extendQuery(query, inner);
  // When all project get pushed into DruidQuery, the project can be replaced by DruidQuery.
  if (outer != null) {
   Project newProject = outer.copy(outer.getTraitSet(), newQuery, outer.getProjects(),
     outer.getRowType());
   call.transformTo(newProject);
  } else {
   call.transformTo(newQuery);
  }
 }
}

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

Project

相关文章

    查看更多

    热门标签

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

    最新文章

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