Package org.apache.calcite.rel.stream

Class StreamRules

java.lang.Object

org.apache.calcite.rel.stream.StreamRules

public class StreamRules
extends Object

Rules and relational operators for streaming relational expressions.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamRules.DeltaAggregateTransposeRule	Planner rule that pushes a Delta through an Aggregate.
static class	StreamRules.DeltaFilterTransposeRule	Planner rule that pushes a Delta through a Filter.
static class	StreamRules.DeltaJoinTransposeRule	Planner rule that pushes a Delta through a Join.
static class	StreamRules.DeltaProjectTransposeRule	Planner rule that pushes a Delta through a Project.
static class	StreamRules.DeltaSortTransposeRule	Planner rule that pushes a Delta through an Sort.
static class	StreamRules.DeltaTableScanRule	Planner rule that pushes a Delta into a TableScan of a StreamableTable.
static class	StreamRules.DeltaTableScanToEmptyRule	Planner rule that converts Delta over a TableScan of a table other than StreamableTable to an empty Values.
static class	StreamRules.DeltaUnionTransposeRule	Planner rule that pushes a Delta through an Union.

Field Summary

Fields

Modifier and Type	Field	Description
static final com.google.common.collect.ImmutableList<RelOptRule>	RULES

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

RULES

public static final com.google.common.collect.ImmutableList<RelOptRule> RULES