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
Constructor and Description |
---|
PlanDynamicPruningFilters(SparkSession sparkSession) |
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() |
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
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
$init$, canEvaluate, canEvaluateWithinJoin, findExpressionAndTrackLineageDown, replaceAlias, splitConjunctivePredicates, splitDisjunctivePredicates
$init$, productArity, productElement, productIterator, productPrefix
initializeLogging
public PlanDynamicPruningFilters(SparkSession sparkSession)
public static String toString()
public SparkSession sparkSession()
public org.apache.spark.sql.execution.SparkPlan apply(org.apache.spark.sql.execution.SparkPlan plan)
apply
in class org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.execution.SparkPlan>