public class LeftSemiJoinBNL extends SparkPlan implements scala.Product, scala.Serializable
Constructor and Description |
---|
LeftSemiJoinBNL(SparkPlan streamed,
SparkPlan broadcast,
scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> condition) |
Modifier and Type | Method and Description |
---|---|
scala.Function1<org.apache.spark.sql.catalyst.expressions.Row,Object> |
boundCondition() |
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() |
codegenEnabled, executeCollect, makeCopy, requiredChildDistribution
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
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
productArity, productElement, productIterator, productPrefix
initialized, initializeIfNecessary, initializeLogging, initLock, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public SparkPlan streamed()
public SparkPlan broadcast()
public scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> condition()
public org.apache.spark.sql.catalyst.plans.physical.Partitioning outputPartitioning()
SparkPlan
outputPartitioning
in class SparkPlan
public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output()
output
in class org.apache.spark.sql.catalyst.plans.QueryPlan<SparkPlan>
public SparkPlan left()
public SparkPlan right()
public scala.Function1<org.apache.spark.sql.catalyst.expressions.Row,Object> boundCondition()