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:

com.typesafe.scalalogging.slf4j.Logging

Direct Known Subclasses:

Aggregate, BroadcastNestedLoopJoin, CacheCommand, CartesianProduct, DescribeCommand, DescribeHiveTableCommand, Distinct, Exchange, ExistingRdd, ExplainCommand, Filter, Generate, HashJoin, HiveTableScan, InsertIntoHiveTable, InsertIntoParquetTable, LeftSemiJoinBNL, LeftSemiJoinHash, Limit, NativeCommand, ParquetTableScan, Project, Sample, ScriptTransformation, SetCommand, Sort, TakeOrdered, Union

public abstract class SparkPlan
extends org.apache.spark.sql.catalyst.plans.QueryPlan<SparkPlan>
implements com.typesafe.scalalogging.slf4j.Logging

:: DeveloperApi ::

Constructor Summary

Constructors

Constructor and Description
SparkPlan()

Method Summary

Methods

Modifier and Type	Method and Description
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.
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, generateSchemaString, generateSchemaString, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionDown$1, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionUp$1, output, outputSet, printSchema, 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, makeCopy, 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 com.typesafe.scalalogging.slf4j.Logging

logger

Constructor Detail

SparkPlan

public SparkPlan()

Method Detail

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.