package joinJudgement
Type Members
-
final
class
DedupParams extends Serializable
Contains information necessary to activate de-dup logic in sub-classes of
JudgementBase. -
class
DuplicatesFilter[U <: Geometry, T <: Geometry] extends Function2[Integer, Iterator[Pair[U, T]], Iterator[Pair[U, T]]]
Provides optional de-dup logic.
Provides optional de-dup logic. Due to the nature of spatial partitioning, the same pair of geometries may appear in multiple partitions. If that pair satisfies join condition, it will be included in join results multiple times. This duplication can be avoided by (1) choosing spatial partitioning that doesn't allow for overlapping partition extents and (2) reporting a pair of matching geometries only from the partition whose extent contains the reference point of the intersection of the geometries.
- class DynamicIndexLookupJudgement[T <: Geometry, U <: Geometry] extends JudgementBase[T, U] with FlatMapFunction2[Iterator[U], Iterator[T], Pair[U, T]] with Serializable
- class LeftIndexLookupJudgement[T <: Geometry, U <: Geometry] extends JudgementBase[T, U] with FlatMapFunction2[Iterator[SpatialIndex], Iterator[U], Pair[U, T]] with Serializable
- class NestedLoopJudgement[T <: Geometry, U <: Geometry] extends JudgementBase[T, U] with FlatMapFunction2[Iterator[T], Iterator[U], Pair[U, T]] with Serializable
- class RightIndexLookupJudgement[T <: Geometry, U <: Geometry] extends JudgementBase[T, U] with FlatMapFunction2[Iterator[T], Iterator[SpatialIndex], Pair[U, T]] with Serializable