org.apache.spark.sql.execution.joins

Class LeftSemiJoinBNL

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.joins.LeftSemiJoinBNL

All Implemented Interfaces:

java.io.Serializable, Logging, org.apache.spark.sql.catalyst.trees.BinaryNode<SparkPlan>, scala.Equals, scala.Product

public class LeftSemiJoinBNL
extends SparkPlan
implements BinaryNode, scala.Product, scala.Serializable

:: DeveloperApi :: Using BroadcastNestedLoopJoin to calculate left semi join result when there's no join keys for hash join.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LeftSemiJoinBNL(SparkPlan streamed, SparkPlan broadcast, scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> condition)

Method Summary

Methods

Modifier and Type	Method and Description
SparkPlan	broadcast()
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.
SparkPlan	left() The Streamed Relation
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() The Broadcast relation
SparkPlan	streamed()

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, 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, statePrefix, 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, 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 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

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

Constructor Detail

LeftSemiJoinBNL

public LeftSemiJoinBNL(SparkPlan streamed,
               SparkPlan broadcast,
               scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> condition)

Method Detail

streamed

public SparkPlan streamed()

broadcast

public SparkPlan broadcast()

condition

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

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>

left

public SparkPlan left()

The Streamed Relation

Specified by:

left in interface org.apache.spark.sql.catalyst.trees.BinaryNode<SparkPlan>

right

public SparkPlan right()

The Broadcast relation

Specified by:

right in interface org.apache.spark.sql.catalyst.trees.BinaryNode<SparkPlan>

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