org.apache.flink.table.planner.plan.rules.logical

Interface FlinkFilterJoinRule.Config

All Superinterfaces:

org.apache.calcite.plan.RelRule.Config

All Known Subinterfaces:

FlinkFilterJoinRule.FlinkFilterIntoJoinRule.FlinkFilterIntoJoinRuleConfig, FlinkFilterJoinRule.FlinkJoinConditionPushRule.FlinkFilterJoinRuleConfig

Enclosing class:

FlinkFilterJoinRule<C extends FlinkFilterJoinRule.Config>

public static interface FlinkFilterJoinRule.Config
extends org.apache.calcite.plan.RelRule.Config

Rule configuration.

Method Summary

Modifier and Type	Method and Description
FlinkFilterJoinRule.Predicate	getPredicate() Predicate that returns whether a filter is valid in the ON clause of a join for this particular kind of join.
default boolean	isSmart() Whether to try to strengthen join-type, default false.
FlinkFilterJoinRule.Config	withPredicate(FlinkFilterJoinRule.Predicate predicate) Sets getPredicate().
FlinkFilterJoinRule.Config	withSmart(boolean smart) Sets isSmart().

Methods inherited from interface org.apache.calcite.plan.RelRule.Config

as, description, operandSupplier, relBuilderFactory, toRule, withDescription, withOperandSupplier, withRelBuilderFactory

Method Detail

isSmart

@Value.Default
default boolean isSmart()

Whether to try to strengthen join-type, default false.

withSmart

FlinkFilterJoinRule.Config withSmart(boolean smart)

Sets isSmart().

getPredicate

@Value.Parameter
FlinkFilterJoinRule.Predicate getPredicate()

Predicate that returns whether a filter is valid in the ON clause of a join for this particular kind of join. If not, Calcite will push it back to above the join.

withPredicate

FlinkFilterJoinRule.Config withPredicate(FlinkFilterJoinRule.Predicate predicate)

Sets getPredicate().