org.apache.spark.sql.execution

Class SparkLogicalPlan

Object

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

org.apache.spark.sql.catalyst.plans.QueryPlan<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan

org.apache.spark.sql.execution.SparkLogicalPlan

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation, scala.Equals, scala.Product

public class SparkLogicalPlan
extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan
implements org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation, scala.Product, scala.Serializable

:: DeveloperApi :: Allows already planned SparkQueries to be linked into logical query plans.

Note that in general it is not valid to use this class to link multiple copies of the same physical operator into the same query plan as this violates the uniqueness of expression ids. Special handling exists for ExistingRdd as these are already leaf operators and thus we can just replace the output attributes with new copies of themselves without breaking any attribute linking.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkLogicalPlan(SparkPlan alreadyPlanned)

Method Summary

Methods

Modifier and Type	Method and Description
SparkPlan	alreadyPlanned()
scala.collection.immutable.Nil$	children()
SparkLogicalPlan	newInstance()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
scala.collection.immutable.Set<org.apache.spark.sql.catalyst.expressions.Attribute>	references()

Methods inherited from class org.apache.spark.sql.catalyst.plans.logical.LogicalPlan

childrenResolved, inputSet, resolve, resolved

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, outputSet, printSchema, schemaString, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUp

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

apply, argString, asCode, 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 scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

SparkLogicalPlan

public SparkLogicalPlan(SparkPlan alreadyPlanned)

Method Detail

alreadyPlanned

public SparkPlan alreadyPlanned()

output

public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output()

Specified by:

output in class org.apache.spark.sql.catalyst.plans.QueryPlan<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

references

public scala.collection.immutable.Set<org.apache.spark.sql.catalyst.expressions.Attribute> references()

Specified by:

references in class org.apache.spark.sql.catalyst.plans.logical.LogicalPlan

children

public scala.collection.immutable.Nil$ children()

newInstance

public final SparkLogicalPlan newInstance()

Specified by:

newInstance in interface org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation