Packages

o

geotrellis.spark.join

VectorJoin

object VectorJoin

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. VectorJoin
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def apply[L, R](left: RDD[L], right: RDD[R], pred: (Geometry, Geometry) ⇒ Boolean)(implicit arg0: ClassTag[L], arg1: (L) ⇒ Geometry, arg2: ClassTag[R], arg3: (R) ⇒ Geometry, sc: SparkContext): RDD[(L, R)]

    Perform the vector join operation over an RDD[L] and and RDD[R], where both L and R are viewable as Geometry.

    Perform the vector join operation over an RDD[L] and and RDD[R], where both L and R are viewable as Geometry. This makes use of the FilteredCartesianRDD type to accelerate the process (relative to plain-old CartesianRDD).

    It is assumed that geometries in each partition of left and right RDDs are spatially related, such that each partition in left may have a limited number of potentially intersecting partitions in right.

    left

    An RDD[L], where L is viewable as a Geometry

    right

    An RDD[R], where R is viewable as a Geometry

    pred

    A predicate which answers whether an L and an R should be joined

    returns

    An RDD of L-R pairs

  2. def calculateEnvelope[T](gs: Iterator[T])(implicit arg0: (T) ⇒ Geometry): Iterator[Envelope]

    A function which calculates the envelope of a partition.

    A function which calculates the envelope of a partition.

    gs

    An iterator containing the contents of the RDD

    returns

    An Iterator containing one envelope