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, WindowFn windowFn, Trigger trigger, int windowFieldIdx, Duration allowedLatence)

Method Summary

Modifier and Type	Method and Description
PCollection<BeamRecord>	buildBeamPipeline(PCollectionTuple inputPCollections, BeamSqlEnv sqlEnv) A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.
Aggregate	copy(RelTraitSet traitSet, RelNode input, boolean indicator, ImmutableBitSet groupSet, java.util.List<ImmutableBitSet> groupSets, java.util.List<AggregateCall> aggCalls)
RelWriter	explainTerms(RelWriter pw)
void	setTrigger(Trigger trigger)
void	setWindowFn(WindowFn windowFn)

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,
                          WindowFn windowFn,
                          Trigger trigger,
                          int windowFieldIdx,
                          Duration allowedLatence)

Method Detail

buildBeamPipeline

public PCollection<BeamRecord> buildBeamPipeline(PCollectionTuple inputPCollections,
                                                 BeamSqlEnv sqlEnv)
                                          throws java.lang.Exception

Description copied from interface: BeamRelNode

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

Specified by:

buildBeamPipeline in interface BeamRelNode

Throws:

java.lang.Exception

copy

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

setWindowFn

public void setWindowFn(WindowFn windowFn)

setTrigger

public void setTrigger(Trigger trigger)

explainTerms

public RelWriter explainTerms(RelWriter pw)