org.apache.spark.sql.sources

Class LogicalRelation

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.catalyst.plans.logical.LeafNode

org.apache.spark.sql.sources.LogicalRelation

All Implemented Interfaces:

java.io.Serializable, Logging, org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation, org.apache.spark.sql.catalyst.trees.LeafNode<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>, scala.Equals, scala.Product

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

Used to link a BaseRelation in to a logical query plan.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LogicalRelation(BaseRelation relation)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.expressions.AttributeMap<org.apache.spark.sql.catalyst.expressions.AttributeReference>	attributeMap() Used to lookup original attribute capitalization
boolean	equals(Object other)
LogicalRelation	newInstance()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AttributeReference>	output()
BaseRelation	relation()
boolean	sameResult(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan otherPlan)
String	simpleString()
org.apache.spark.sql.catalyst.plans.logical.Statistics	statistics()

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

children

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_, org$apache$spark$sql$catalyst$plans$logical$LogicalPlan$$resolveAsColumn, org$apache$spark$sql$catalyst$plans$logical$LogicalPlan$$resolveAsTableColumn, 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, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUp

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

apply, argString, asCode, collect, fastEquals, flatMap, foreach, foreachUp, generateTreeString, getNodeNumbered, makeCopy, map, mapChildren, nodeName, numberedTreeString, origin, otherCopyArgs, stringArgs, toString, transform, transformChildrenDown, transformChildrenUp, transformDown, transformUp, treeString, withNewChildren

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, log_

Constructor Detail

LogicalRelation

public LogicalRelation(BaseRelation relation)

Method Detail

relation

public BaseRelation relation()

output

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

equals

public boolean equals(Object other)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class Object

sameResult

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

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

attributeMap

public org.apache.spark.sql.catalyst.expressions.AttributeMap<org.apache.spark.sql.catalyst.expressions.AttributeReference> attributeMap()

Used to lookup original attribute capitalization

newInstance

public LogicalRelation newInstance()

Specified by:

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

simpleString

public String simpleString()

Overrides:

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