org.apache.spark.sql.execution

Interface HashJoin

All Known Implementing Classes:

BroadcastHashJoin, LeftSemiJoinHash, ShuffledHashJoin

public interface HashJoin

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>	buildKeys()
SparkPlan	buildPlan()
BuildSide	buildSide()
org.apache.spark.sql.catalyst.expressions.Projection	buildSideKeyGenerator()
scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row>	joinIterators(scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row> buildIter, scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row> streamIter)
SparkPlan	left()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>	leftKeys()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
SparkPlan	right()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>	rightKeys()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>	streamedKeys()
SparkPlan	streamedPlan()
scala.Function0<org.apache.spark.sql.catalyst.expressions.MutableProjection>	streamSideKeyGenerator()

Method Detail

leftKeys

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> leftKeys()

rightKeys

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> rightKeys()

buildSide

BuildSide buildSide()

left

SparkPlan left()

right

SparkPlan right()

buildPlan

SparkPlan buildPlan()

streamedPlan

SparkPlan streamedPlan()

buildKeys

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> buildKeys()

streamedKeys

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> streamedKeys()

output

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

buildSideKeyGenerator

org.apache.spark.sql.catalyst.expressions.Projection buildSideKeyGenerator()

streamSideKeyGenerator

scala.Function0<org.apache.spark.sql.catalyst.expressions.MutableProjection> streamSideKeyGenerator()

joinIterators

scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row> joinIterators(scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row> buildIter,
                                                                                     scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row> streamIter)