org.apache.spark.sql.dynamicpruning

Class PlanDynamicPruningFilters

Object

org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.execution.SparkPlan>

org.apache.spark.sql.dynamicpruning.PlanDynamicPruningFilters

All Implemented Interfaces:

java.io.Serializable, Logging, org.apache.spark.sql.catalyst.expressions.PredicateHelper, scala.Equals, scala.Product

public class PlanDynamicPruningFilters
extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.execution.SparkPlan>
implements org.apache.spark.sql.catalyst.expressions.PredicateHelper, scala.Product, scala.Serializable

This planner rule aims at rewriting dynamic pruning predicates in order to reuse the results of broadcast. For joins that are not planned as broadcast hash joins we keep the fallback mechanism with subquery duplicate.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PlanDynamicPruningFilters(SparkSession sparkSession)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.execution.SparkPlan	apply(org.apache.spark.sql.execution.SparkPlan plan)
SparkSession	sparkSession()
static String	toString()

Methods inherited from class org.apache.spark.sql.catalyst.rules.Rule

initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, ruleName

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.sql.catalyst.expressions.PredicateHelper

$init$, canEvaluate, canEvaluateWithinJoin, findExpressionAndTrackLineageDown, replaceAlias, splitConjunctivePredicates, splitDisjunctivePredicates

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface org.apache.spark.internal.Logging

initializeLogging

Constructor Detail

PlanDynamicPruningFilters

public PlanDynamicPruningFilters(SparkSession sparkSession)

Method Detail

toString

public static String toString()

sparkSession

public SparkSession sparkSession()

apply

public org.apache.spark.sql.execution.SparkPlan apply(org.apache.spark.sql.execution.SparkPlan plan)

Specified by:

apply in class org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.execution.SparkPlan>