org.apache.spark.sql.execution

Class LogicalRDD

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.LogicalRDD

All Implemented Interfaces:

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

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

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.immutable.Nil$	children()
LogicalRDD	newInstance()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
RDD<org.apache.spark.sql.catalyst.expressions.Row>	rdd()
boolean	sameResult(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)
org.apache.spark.sql.catalyst.plans.logical.Statistics	statistics()

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

childrenResolved, cleanArgs, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$Logging$$log__$eq, org$apache$spark$Logging$$log_, resolve, resolve, resolveChildren, resolved, statePrefix

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

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

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

apply, argString, asCode, collect, fastEquals, flatMap, foreach, generateTreeString, getNodeNumbered, makeCopy, map, mapChildren, nodeName, numberedTreeString, otherCopyArgs, 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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, log_

Constructor Detail

LogicalRDD

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

Method Detail

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>

rdd

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

children

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

newInstance

public LogicalRDD newInstance()

Specified by:

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

sameResult

public boolean sameResult(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)

Overrides:

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

statistics

public org.apache.spark.sql.catalyst.plans.logical.Statistics statistics()

Overrides:

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