org.apache.beam.sdk.extensions.sql.impl.rel

Class BeamAggregationRel

java.lang.Object

Aggregate

org.apache.beam.sdk.extensions.sql.impl.rel.BeamAggregationRel

All Implemented Interfaces:

BeamRelNode

public class BeamAggregationRel
extends Aggregate
implements BeamRelNode

BeamRelNode to replace a Aggregate node.

Constructor Summary

Constructors

Constructor and Description
BeamAggregationRel(RelOptCluster cluster, RelTraitSet traits, RelNode child, boolean indicator, ImmutableBitSet groupSet, java.util.List<ImmutableBitSet> groupSets, java.util.List<AggregateCall> aggCalls, java.util.Optional<AggregateWindowField> windowField)

Method Summary

Modifier and Type	Method and Description
Aggregate	copy(RelTraitSet traitSet, RelNode input, boolean indicator, ImmutableBitSet groupSet, java.util.List<ImmutableBitSet> groupSets, java.util.List<AggregateCall> aggCalls)
RelWriter	explainTerms(RelWriter pw)
PTransform<PCollectionTuple,PCollection<Row>>	toPTransform() A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BeamAggregationRel

public BeamAggregationRel(RelOptCluster cluster,
                          RelTraitSet traits,
                          RelNode child,
                          boolean indicator,
                          ImmutableBitSet groupSet,
                          java.util.List<ImmutableBitSet> groupSets,
                          java.util.List<AggregateCall> aggCalls,
                          java.util.Optional<AggregateWindowField> windowField)

Method Detail

toPTransform

public PTransform<PCollectionTuple,PCollection<Row>> toPTransform()

Description copied from interface: BeamRelNode

A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.

Specified by:

toPTransform in interface BeamRelNode

copy

public Aggregate copy(RelTraitSet traitSet,
                      RelNode input,
                      boolean indicator,
                      ImmutableBitSet groupSet,
                      java.util.List<ImmutableBitSet> groupSets,
                      java.util.List<AggregateCall> aggCalls)

explainTerms

public RelWriter explainTerms(RelWriter pw)