org.apache.spark.sql.execution

Class BroadcastNestedLoopJoin

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

All Implemented Interfaces:

java.io.Serializable, Logging, scala.Equals, scala.Product

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

:: DeveloperApi ::

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BroadcastNestedLoopJoin(SparkPlan left, SparkPlan right, BuildSide buildSide, org.apache.spark.sql.catalyst.plans.JoinType joinType, scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> condition)

Method Summary

Methods

Modifier and Type	Method and Description
scala.Function1<org.apache.spark.sql.catalyst.expressions.Row,Object>	boundCondition()
SparkPlan	broadcast()
BuildSide	buildSide()
scala.Option<org.apache.spark.sql.catalyst.expressions.Expression>	condition()
RDD<org.apache.spark.sql.catalyst.expressions.Row>	execute() Runs this query returning the result as an RDD.
org.apache.spark.sql.catalyst.plans.JoinType	joinType()
SparkPlan	left()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
org.apache.spark.sql.catalyst.plans.physical.Partitioning	outputPartitioning() Specifies how data is partitioned across different nodes in the cluster.
SparkPlan	right()
SparkPlan	streamed() BuildRight means the right relation <=> the broadcast relation.

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

codegenEnabled, executeCollect, makeCopy, 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, printSchema, schema, 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, 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.BinaryNode

children

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

initialized, initializeIfNecessary, initializeLogging, initLock, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

BroadcastNestedLoopJoin

public BroadcastNestedLoopJoin(SparkPlan left,
                       SparkPlan right,
                       BuildSide buildSide,
                       org.apache.spark.sql.catalyst.plans.JoinType joinType,
                       scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> condition)

Method Detail

left

public SparkPlan left()

right

public SparkPlan right()

buildSide

public BuildSide buildSide()

joinType

public org.apache.spark.sql.catalyst.plans.JoinType joinType()

condition

public scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> condition()

streamed

public SparkPlan streamed()

BuildRight means the right relation <=> the broadcast relation.

broadcast

public SparkPlan broadcast()

outputPartitioning

public org.apache.spark.sql.catalyst.plans.physical.Partitioning outputPartitioning()

Description copied from class: SparkPlan

Specifies how data is partitioned across different nodes in the cluster.

Overrides:

outputPartitioning in class SparkPlan

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>

boundCondition

public scala.Function1<org.apache.spark.sql.catalyst.expressions.Row,Object> boundCondition()

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