Package org.eigenbase.rel

Examples of org.eigenbase.rel.RelNode

115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
      return DirectPlan.createDirectPlan(context, false, String.format("Error: %s", e.getMessage()));
    }
  }

  private DrillRel convertToDrel(RelNode relNode, AbstractSchema schema, String tableName) throws RelConversionException {
    RelNode convertedRelNode = planner.transform(DrillSqlWorker.LOGICAL_RULES,
        relNode.getTraitSet().plus(DrillRel.DRILL_LOGICAL), relNode);

    if (convertedRelNode instanceof DrillStoreRel)
      throw new UnsupportedOperationException();

    DrillWriterRel writerRel = new DrillWriterRel(convertedRelNode.getCluster(), convertedRelNode.getTraitSet(),
        convertedRelNode, schema.createNewTable(tableName));
    return new DrillScreenRel(writerRel.getCluster(), writerRel.getTraitSet(), writerRel);
  }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
46
  }

  @Override
  public void onMatch(RelOptRuleCall call) {
    final DrillScreenRelBase screen = (DrillScreenRelBase) call.rel(0);
    final RelNode input = call.rel(1);

    final RelTraitSet traits = input.getTraitSet().plus(Prel.DRILL_PHYSICAL).plus(DrillDistributionTrait.SINGLETON);
    final RelNode convertedInput = convert(input, traits);
    DrillScreenRelBase newScreen = new ScreenPrel(screen.getCluster(), screen.getTraitSet().plus(Prel.DRILL_PHYSICAL).plus(DrillDistributionTrait.SINGLETON), convertedInput);
    call.transformTo(newScreen);
  }
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
    boolean transform = false;

    for (RelNode rel : ((RelSubset)candidateSet).getRelList()) {
      if (!isDefaultDist(rel)) {
        RelNode out = convertChild(n, rel);
        if(out != null){
          call.transformTo(out);
          transform = true;

        }
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
  @Override
  public RelOptCost computeSelfCost(RelOptPlanner planner) {
    if(PrelUtil.getSettings(getCluster()).useDefaultCosting()) {
      return super.computeSelfCost(planner).multiplyBy(.1);
    }
    RelNode child = this.getChild();
    double inputRows = RelMetadataQuery.getRowCount(child);

    int numGroupByFields = this.getGroupCount();
    int numAggrFields = this.aggCalls.size();
    // cpu cost of hashing each grouping key
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
  }

  @Override
  public void onMatch(RelOptRuleCall call) {
    final DrillProjectRel project = (DrillProjectRel) call.rel(0);
    final RelNode input = project.getChild();

    RelTraitSet traits = input.getTraitSet().plus(Prel.DRILL_PHYSICAL);
    RelNode convertedInput = convert(input, traits);

    Map<Integer, Integer> inToOut = getProjectMap(project);
    boolean traitPull = new ProjectTraitPull(call, inToOut).go(project, convertedInput);

    if(!traitPull){
      call.transformTo(new ProjectPrel(project.getCluster(), convertedInput.getTraitSet(), convertedInput, project.getProjects(), project.getRowType()));
    }
  }
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
    // For project, we need make sure that the project's field name is same as the input,
    // when the project expression is RexInPutRef. This is necessary since Optiq may use
    // an arbitrary name for the project's field name.
    if (prel instanceof ProjectPrel) {
      RelNode child = children.get(0);

      List<String> fieldNames = Lists.newArrayList();

      for (Pair<String, RexNode> pair : Pair.zip(prel.getRowType().getFieldNames(), ((ProjectPrel) prel).getProjects())) {
        if (pair.right instanceof RexInputRef) {
          String name = child.getRowType().getFieldNames().get(((RexInputRef) pair.right).getIndex());
          fieldNames.add(name);
        } else {
          fieldNames.add(pair.left);
        }
      }
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    List<RelNode> convertedInputList = Lists.newArrayList();
    RelTraitSet traits = call.getPlanner().emptyTraitSet().plus(Prel.DRILL_PHYSICAL);
   
    try {
      for (int i = 0; i < inputs.size(); i++) {
        RelNode convertedInput = convert(inputs.get(i), PrelUtil.fixTraits(call, traits));
        convertedInputList.add(convertedInput);   
      }
     
      traits = call.getPlanner().emptyTraitSet().plus(Prel.DRILL_PHYSICAL).plus(DrillDistributionTrait.SINGLETON);
      UnionAllPrel unionAll = new UnionAllPrel(union.getCluster(), traits, convertedInputList);
View Full Code Here
57
58
59
60
61
62
63
64
  }

  @Override
  public Prel visitScreen(ScreenPrel prel, MajorFragmentStat s) throws RuntimeException {
    s.setSingular();
    RelNode child = ((Prel)prel.getChild()).accept(this, s);
    return (Prel) prel.copy(prel.getTraitSet(), Collections.singletonList(child));
  }
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
69
    final int leftCount = children.get(0).getRowType().getFieldCount();

    List<RelNode> reNamedChildren = Lists.newArrayList();

    RelNode left = prel.getJoinInput(0, children.get(0));
    RelNode right = prel.getJoinInput(leftCount, children.get(1));

    reNamedChildren.add(left);
    reNamedChildren.add(right);

    return (Prel) prel.copy(prel.getTraitSet(), reNamedChildren);
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
71
72
73
  @Override
  public RelOptCost computeSelfCost(RelOptPlanner planner) {
    if(PrelUtil.getSettings(getCluster()).useDefaultCosting()) {
      return super.computeSelfCost(planner).multiplyBy(.1);
    }
    RelNode child = this.getChild();
    double inputRows = RelMetadataQuery.getRowCount(child);

    int  rowWidth = child.getRowType().getFieldCount() * DrillCostBase.AVG_FIELD_WIDTH;
    double hashCpuCost = DrillCostBase.HASH_CPU_COST * inputRows * distFields.size();
    double svrCpuCost = DrillCostBase.SVR_CPU_COST * inputRows;
    double mergeCpuCost = DrillCostBase.COMPARE_CPU_COST * inputRows * (Math.log(numEndPoints)/Math.log(2));
    double networkCost = DrillCostBase.BYTE_NETWORK_COST * inputRows * rowWidth;
    DrillCostFactory costFactory = (DrillCostFactory)planner.getCostFactory();
View Full Code Here
TOP

Related Classes of org.eigenbase.rel.RelNode

  • cascading.lingual.optiq.CascadingAggregateConverterRule
  • cascading.lingual.optiq.CascadingAggregateRel
  • cascading.lingual.optiq.CascadingCalcConverterRule
  • cascading.lingual.optiq.CascadingJoinRule
  • cascading.lingual.optiq.CascadingProjectConverterRule
  • cascading.lingual.optiq.CascadingSortRel
  • cascading.lingual.optiq.CascadingTableModificationConverterRule
  • cascading.lingual.tap.TapTable
  • net.hydromatic.optiq.impl.spark.SparkHandlerImpl
  • net.hydromatic.optiq.impl.ViewTable
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.