org.apache.spark.sql.execution

Class SparkPlan

Object

org.apache.spark.sql.catalyst.trees.TreeNode<PlanType>

org.apache.spark.sql.catalyst.plans.QueryPlan<SparkPlan>

org.apache.spark.sql.execution.SparkPlan

All Implemented Interfaces:

java.io.Serializable, Logging

Direct Known Subclasses:

Aggregate, AnalyzeTable, BatchPythonEvaluation, BroadcastHashJoin, BroadcastNestedLoopJoin, CacheCommand, CartesianProduct, DescribeCommand, DescribeHiveTableCommand, Distinct, DropTable, Except, Exchange, ExistingRdd, ExplainCommand, Filter, Generate, GeneratedAggregate, HashOuterJoin, HiveTableScan, InsertIntoHiveTable, InsertIntoParquetTable, Intersect, LeftSemiJoinBNL, LeftSemiJoinHash, Limit, NativeCommand, OutputFaker, ParquetTableScan, Project, Sample, ScriptTransformation, SetCommand, ShuffledHashJoin, Sort, TakeOrdered, Union

public abstract class SparkPlan
extends org.apache.spark.sql.catalyst.plans.QueryPlan<SparkPlan>
implements Logging, scala.Serializable

:: DeveloperApi ::

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkPlan()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	codegenEnabled()
abstract RDD<org.apache.spark.sql.catalyst.expressions.Row>	execute() Runs this query returning the result as an RDD.
org.apache.spark.sql.catalyst.expressions.Row[]	executeCollect() Runs this query returning the result as an array.
SparkPlan	makeCopy(Object[] newArgs) Overridden make copy also propogates sqlContext to copied plan.
org.apache.spark.sql.catalyst.plans.physical.Partitioning	outputPartitioning() Specifies how data is partitioned across different nodes in the cluster.
scala.collection.Seq<org.apache.spark.sql.catalyst.plans.physical.Distribution>	requiredChildDistribution() Specifies any partition requirements on the input data for this operator.

Methods inherited from class org.apache.spark.sql.catalyst.plans.QueryPlan

expressions, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionDown$1, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionUp$1, output, outputSet, printSchema, schema, schemaString, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUp

Methods inherited from class org.apache.spark.sql.catalyst.trees.TreeNode

apply, argString, asCode, children, collect, fastEquals, flatMap, foreach, generateTreeString, getNodeNumbered, id, map, mapChildren, nextId, nodeName, numberedTreeString, otherCopyArgs, sameInstance, simpleString, stringArgs, toString, transform, transformChildrenDown, transformChildrenUp, transformDown, transformUp, treeString, withNewChildren

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initialized, initializeIfNecessary, initializeLogging, initLock, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

SparkPlan

public SparkPlan()

Method Detail

codegenEnabled

public boolean codegenEnabled()

makeCopy

public SparkPlan makeCopy(Object[] newArgs)

Overridden make copy also propogates sqlContext to copied plan.

Overrides:

makeCopy in class org.apache.spark.sql.catalyst.trees.TreeNode<SparkPlan>

outputPartitioning

public org.apache.spark.sql.catalyst.plans.physical.Partitioning outputPartitioning()

Specifies how data is partitioned across different nodes in the cluster.

requiredChildDistribution

public scala.collection.Seq<org.apache.spark.sql.catalyst.plans.physical.Distribution> requiredChildDistribution()

Specifies any partition requirements on the input data for this operator.

execute

public abstract RDD<org.apache.spark.sql.catalyst.expressions.Row> execute()

Runs this query returning the result as an RDD.

executeCollect

public org.apache.spark.sql.catalyst.expressions.Row[] executeCollect()

Runs this query returning the result as an array.