public static class DataStreamRetractionRules.SetAccModeRule
extends org.apache.calcite.plan.RelOptRule
AccMode
of DataStreamRel
nodes.Constructor and Description |
---|
SetAccModeRule() |
Modifier and Type | Method and Description |
---|---|
boolean |
consumesRetractions(org.apache.calcite.rel.RelNode relNode)
Checks if a
RelNode consumes retraction messages instead of forwarding them. |
boolean |
forwardsRetractions(org.apache.calcite.rel.RelNode parent,
scala.collection.Seq<org.apache.calcite.rel.RelNode> children)
Checks if a
RelNode forwards retraction messages from its children. |
void |
onMatch(org.apache.calcite.plan.RelOptRuleCall call)
Updates the
AccMode of a RelNode and its children if necessary. |
boolean |
producesRetractions(org.apache.calcite.rel.RelNode node)
Checks if a
RelNode produces retraction messages. |
boolean |
producesUpdates(org.apache.calcite.rel.RelNode relNode)
Checks if a
RelNode produces update and delete changes. |
org.apache.calcite.rel.RelNode |
setAccRetract(org.apache.calcite.rel.RelNode relNode)
Set
AccMode.AccRetract to a RelNode . |
public boolean producesUpdates(org.apache.calcite.rel.RelNode relNode)
RelNode
produces update and delete changes.relNode
- (undocumented)public org.apache.calcite.rel.RelNode setAccRetract(org.apache.calcite.rel.RelNode relNode)
AccMode.AccRetract
to a RelNode
.relNode
- (undocumented)public boolean consumesRetractions(org.apache.calcite.rel.RelNode relNode)
RelNode
consumes retraction messages instead of forwarding them.
The node might or might not produce new retraction messages.
This is checked by producesRetractions()
.relNode
- (undocumented)public boolean producesRetractions(org.apache.calcite.rel.RelNode node)
RelNode
produces retraction messages.node
- (undocumented)public boolean forwardsRetractions(org.apache.calcite.rel.RelNode parent, scala.collection.Seq<org.apache.calcite.rel.RelNode> children)
RelNode
forwards retraction messages from its children.parent
- (undocumented)children
- (undocumented)public void onMatch(org.apache.calcite.plan.RelOptRuleCall call)
AccMode
of a RelNode
and its children if necessary.onMatch
in class org.apache.calcite.plan.RelOptRule
call
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.