join

Ordering

Visibility

case class DistanceJoinExec(left: SparkPlan, right: SparkPlan, leftShape: Expression, rightShape: Expression, radius: Expression, intersects: Boolean, extraCondition: Option[Expression] = None) extends SparkPlan with BinaryExecNode with TraitJoinQueryExec with Logging with Product with Serializable
case class RangeJoinExec(left: SparkPlan, right: SparkPlan, leftShape: Expression, rightShape: Expression, intersects: Boolean, extraCondition: Option[Expression] = None) extends SparkPlan with BinaryExecNode with TraitJoinQueryExec with Logging with Product with Serializable
ST_Contains(left, right) - left contains right or ST_Intersects(left, right) - left and right intersect
ST_Contains(left, right) - left contains right or ST_Intersects(left, right) - left and right intersect
left
left side of the join
right
right side of the join
leftShape
expression for the first argument of ST_Contains or ST_Intersects
rightShape
expression for the second argument of ST_Contains or ST_Intersects
intersects
boolean indicating whether spatial relationship is 'intersects' (true) or 'contains' (false)
trait TraitJoinQueryExec extends AnyRef

object JoinQueryDetector extends Strategy
Plans RangeJoinExec for inner joins on spatial relationships ST_Contains(a, b) and ST_Intersects(a, b).
Plans RangeJoinExec for inner joins on spatial relationships ST_Contains(a, b) and ST_Intersects(a, b).
Plans DistanceJoinExec for inner joins on spatial relationship ST_Distance(a, b) < r.

Packages