Examples of AggregateRel

Examples of org.eigenbase.rel.AggregateRel

37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
    super(RelOptRule.some(AggregateRel.class, Convention.NONE, RelOptRule.any(RelNode.class)), "DrillAggregateRule");
  }

  @Override
  public void onMatch(RelOptRuleCall call) {
    final AggregateRel aggregate = (AggregateRel) call.rel(0);
    final RelNode input = call.rel(1);
    final RelTraitSet traits = aggregate.getTraitSet().plus(DrillRel.CONVENTION);
    final RelNode convertedInput = convert(input, traits);
    try {
      call.transformTo(new DrillAggregateRel(aggregate.getCluster(), traits, convertedInput, aggregate.getGroupSet(),
          aggregate.getAggCallList()));
    } catch (InvalidRelException e) {
      tracer.warning(e.toString());
    }
  }
View Full Code Here

Examples of org.eigenbase.rel.AggregateRel

40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
    super(RelOptHelper.some(AggregateRel.class, Convention.NONE, RelOptHelper.any(RelNode.class)), "DrillAggregateRule");
  }

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

    if (aggregate.containsDistinctCall()) {
      // currently, don't use this rule if any of the aggregates contains DISTINCT
      return;
    }

    final RelTraitSet traits = aggregate.getTraitSet().plus(DrillRel.DRILL_LOGICAL);
    final RelNode convertedInput = convert(input, input.getTraitSet().plus(DrillRel.DRILL_LOGICAL));
    try {
      call.transformTo(new DrillAggregateRel(aggregate.getCluster(), traits, convertedInput, aggregate.getGroupSet(),
          aggregate.getAggCallList()));
    } catch (InvalidRelException e) {
      tracer.warning(e.toString());
    }
  }
View Full Code Here

Examples of org.eigenbase.rel.AggregateRel

583
584
585
586
587
588
589
590
591
592
593
   */
  protected AggregateRelBase newAggregateRel(
      AggregateRelBase oldAggRel,
      RelNode inputRel,
      List<AggregateCall> newCalls) {
    return new AggregateRel(
        oldAggRel.getCluster(),
        inputRel,
        oldAggRel.getGroupSet(),
        newCalls);
  }
View Full Code Here

Examples of org.eigenbase.rel.AggregateRel

583
584
585
586
587
588
589
590
591
592
593
   */
  protected AggregateRelBase newAggregateRel(
      AggregateRelBase oldAggRel,
      RelNode inputRel,
      List<AggregateCall> newCalls) {
    return new AggregateRel(
        oldAggRel.getCluster(),
        inputRel,
        oldAggRel.getGroupSet(),
        newCalls);
  }
View Full Code Here

Examples of org.eigenbase.rel.AggregateRel

41
42
43
44
45
46
47
48
49
50
51
52
53
54
  @Override
  public RelNode convert( RelNode rel )
    {
    // stolen from JavaRules.EnumerableAggregateRule
    AggregateRel agg = (AggregateRel) rel;

    RelNode convertedChild = convert( agg.getChild(), agg.getTraitSet().replace( CONVENTION ) );

    if( convertedChild == null )
      return null; // We can't convert the child, so we can't convert rel.

    return new CascadingAggregateRel( rel.getCluster(), rel.getTraitSet(), convertedChild, agg.getGroupSet(), agg.getAggCallList() );
    }
View Full Code Here

Examples of org.eigenbase.rel.AggregateRel

39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
    }

  @Override
  public void onMatch( RelOptRuleCall call )
    {
    AggregateRel rel = call.rel( 0 );

    RelTraitSet newTraits = rel.getTraitSet().plus( Cascading.CONVENTION );

    call.transformTo( new CascadingAggregateRel(
      rel.getCluster(),
      newTraits,
      convert( rel.getChild(), newTraits ),
      rel.getGroupSet(),
      rel.getAggCallList() ) );
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.