org.apache.spark.sql

Class SQLContext.SparkPlanner

java.lang.Object

org.apache.spark.sql.catalyst.planning.QueryPlanner<org.apache.spark.sql.execution.SparkPlan>

org.apache.spark.sql.execution.SparkStrategies

org.apache.spark.sql.SQLContext.SparkPlanner

Enclosing class:

SQLContext

protected class SQLContext.SparkPlanner
extends org.apache.spark.sql.execution.SparkStrategies

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.spark.sql.execution.SparkStrategies

org.apache.spark.sql.execution.SparkStrategies.Aggregation$, org.apache.spark.sql.execution.SparkStrategies.BasicOperators$, org.apache.spark.sql.execution.SparkStrategies.BroadcastNestedLoopJoin$, org.apache.spark.sql.execution.SparkStrategies.CanBroadcast$, org.apache.spark.sql.execution.SparkStrategies.CartesianProduct$, org.apache.spark.sql.execution.SparkStrategies.DDLStrategy$, org.apache.spark.sql.execution.SparkStrategies.EquiJoinSelection$, org.apache.spark.sql.execution.SparkStrategies.HashAggregation$, org.apache.spark.sql.execution.SparkStrategies.InMemoryScans$, org.apache.spark.sql.execution.SparkStrategies.LeftSemiJoin$, org.apache.spark.sql.execution.SparkStrategies.TakeOrderedAndProject$

Constructor Summary

Constructors

Constructor and Description
SQLContext.SparkPlanner()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	codegenEnabled()
int	numPartitions()
org.apache.spark.sql.execution.SparkPlan	pruneFilterProject(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression> projectList, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> filterPredicates, scala.Function1<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>> prunePushedDownFilters, scala.Function1<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>,org.apache.spark.sql.execution.SparkPlan> scanBuilder)
SparkContext	sparkContext()
SQLContext	sqlContext()
scala.collection.Seq<org.apache.spark.sql.catalyst.planning.GenericStrategy<org.apache.spark.sql.execution.SparkPlan>>	strategies()
boolean	unsafeEnabled()

Methods inherited from class org.apache.spark.sql.execution.SparkStrategies

Aggregation, BasicOperators, BroadcastNestedLoopJoin, CanBroadcast, CartesianProduct, DDLStrategy, EquiJoinSelection, HashAggregation, InMemoryScans, LeftSemiJoin, singleRowRdd, TakeOrderedAndProject

Methods inherited from class org.apache.spark.sql.catalyst.planning.QueryPlanner

plan, planLater

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLContext.SparkPlanner

public SQLContext.SparkPlanner()

Method Detail

sparkContext

public SparkContext sparkContext()

sqlContext

public SQLContext sqlContext()

codegenEnabled

public boolean codegenEnabled()

unsafeEnabled

public boolean unsafeEnabled()

numPartitions

public int numPartitions()

strategies

public scala.collection.Seq<org.apache.spark.sql.catalyst.planning.GenericStrategy<org.apache.spark.sql.execution.SparkPlan>> strategies()

Specified by:

strategies in class org.apache.spark.sql.catalyst.planning.QueryPlanner<org.apache.spark.sql.execution.SparkPlan>

pruneFilterProject

public org.apache.spark.sql.execution.SparkPlan pruneFilterProject(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression> projectList,
                                                          scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> filterPredicates,
                                                          scala.Function1<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>> prunePushedDownFilters,
                                                          scala.Function1<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>,org.apache.spark.sql.execution.SparkPlan> scanBuilder)