org.apache.spark.sql.execution.joins

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()
org.apache.spark.sql.execution.joins.BuildSide	buildSide()
org.apache.spark.sql.catalyst.expressions.Projection	buildSideKeyGenerator()
scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row>	hashJoin(scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row> streamIter, HashedRelation hashedRelation)
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

org.apache.spark.sql.execution.joins.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()

hashJoin

scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row> hashJoin(scala.collection.Iterator<org.apache.spark.sql.catalyst.expressions.Row> streamIter,
                                                                                HashedRelation hashedRelation)