org.apache.flink.table.planner.utils

Class DynamicPartitionPruningUtils

java.lang.Object

org.apache.flink.table.planner.utils.DynamicPartitionPruningUtils

public class DynamicPartitionPruningUtils
extends Object

Planner utils for Dynamic partition Pruning.

Constructor Summary

Constructors

Constructor and Description
DynamicPartitionPruningUtils()

Method Summary

Modifier and Type	Method and Description
static List<String>	getSuitableDynamicFilteringFieldsInFactSide(DynamicTableSource tableSource, List<String> candidateFields)
static boolean	supportDynamicPartitionPruning(org.apache.calcite.rel.core.Join join) For the input join node, judge whether the join left side and join right side meet the requirements of dynamic partition pruning.
static boolean	supportDynamicPartitionPruning(org.apache.calcite.rel.core.Join join, boolean factInLeft) For the input join node, judge whether the join left side and join right side meet the requirements of dynamic partition pruning.

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicPartitionPruningUtils

public DynamicPartitionPruningUtils()

Method Detail

supportDynamicPartitionPruning

public static boolean supportDynamicPartitionPruning(org.apache.calcite.rel.core.Join join)

For the input join node, judge whether the join left side and join right side meet the requirements of dynamic partition pruning. Fact side in left or right join is not clear.

supportDynamicPartitionPruning

public static boolean supportDynamicPartitionPruning(org.apache.calcite.rel.core.Join join,
                                                     boolean factInLeft)

For the input join node, judge whether the join left side and join right side meet the requirements of dynamic partition pruning. Fact side in left or right is clear. If meets the requirements, return true.

getSuitableDynamicFilteringFieldsInFactSide

public static List<String> getSuitableDynamicFilteringFieldsInFactSide(DynamicTableSource tableSource,
                                                                       List<String> candidateFields)