org.apache.spark.sql.execution

Class ExistingRdd

Object

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

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

org.apache.spark.sql.execution.SparkPlan

org.apache.spark.sql.execution.ExistingRdd

All Implemented Interfaces:

com.typesafe.scalalogging.slf4j.Logging, java.io.Serializable, scala.Equals, scala.Product

public class ExistingRdd
extends SparkPlan
implements scala.Product, scala.Serializable

:: DeveloperApi ::

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ExistingRdd(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output, RDD<org.apache.spark.sql.catalyst.expressions.Row> rdd)

Method Summary

Methods

Modifier and Type	Method and Description
static Object	convertToCatalyst(Object a)
RDD<org.apache.spark.sql.catalyst.expressions.Row>	execute() Runs this query returning the result as an RDD.
static <A extends scala.Product> ExistingRdd	fromProductRdd(RDD<A> productRdd, scala.reflect.api.TypeTags.TypeTag<A> evidence$1)
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
static <A extends scala.Product> RDD<org.apache.spark.sql.catalyst.expressions.Row>	productToRowRdd(RDD<A> data)
RDD<org.apache.spark.sql.catalyst.expressions.Row>	rdd()

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

executeCollect, outputPartitioning, requiredChildDistribution

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, outputSet, 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 org.apache.spark.sql.catalyst.trees.LeafNode

children

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface com.typesafe.scalalogging.slf4j.Logging

logger

Constructor Detail

ExistingRdd

public ExistingRdd(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output,
           RDD<org.apache.spark.sql.catalyst.expressions.Row> rdd)

Method Detail

convertToCatalyst

public static Object convertToCatalyst(Object a)

productToRowRdd

public static <A extends scala.Product> RDD<org.apache.spark.sql.catalyst.expressions.Row> productToRowRdd(RDD<A> data)

fromProductRdd

public static <A extends scala.Product> ExistingRdd fromProductRdd(RDD<A> productRdd,
                                                   scala.reflect.api.TypeTags.TypeTag<A> evidence$1)

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<SparkPlan>

rdd

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

execute

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

Description copied from class: SparkPlan

Runs this query returning the result as an RDD.

Specified by:

execute in class SparkPlan