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

Class BeamJoinPushThroughJoinRule

java.lang.Object

org.apache.calcite.plan.RelOptRule

org.apache.calcite.rel.rules.JoinPushThroughJoinRule

org.apache.beam.sdk.extensions.sql.impl.rule.BeamJoinPushThroughJoinRule

public class BeamJoinPushThroughJoinRule
extends org.apache.calcite.rel.rules.JoinPushThroughJoinRule

This is exactly similar to JoinPushThroughJoinRule. It only checks if the condition of the new bottom join is supported.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.calcite.plan.RelOptRule	LEFT Instance of the rule that works on logical joins only, and pushes to the left.
static org.apache.calcite.plan.RelOptRule	RIGHT Instance of the rule that works on logical joins only, and pushes to the right.

Fields inherited from class org.apache.calcite.plan.RelOptRule

description, operands, relBuilderFactory

Method Summary

Modifier and Type	Method and Description
void	onMatch(org.apache.calcite.plan.RelOptRuleCall call)

Methods inherited from class org.apache.calcite.plan.RelOptRule

any, convert, convert, convertList, convertOperand, convertOperand, equals, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, matches, none, operand, operand, operand, operand, operand, operandJ, operandJ, some, toString, unordered

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

RIGHT

public static final org.apache.calcite.plan.RelOptRule RIGHT

Instance of the rule that works on logical joins only, and pushes to the right.

LEFT

public static final org.apache.calcite.plan.RelOptRule LEFT

Instance of the rule that works on logical joins only, and pushes to the left.

Method Detail

onMatch

public void onMatch(org.apache.calcite.plan.RelOptRuleCall call)

Overrides:

onMatch in class org.apache.calcite.rel.rules.JoinPushThroughJoinRule