Skip to content

Commit

Permalink
Remove Naive VectorJoin
Browse files Browse the repository at this point in the history
  • Loading branch information
James McClain committed Dec 2, 2016
1 parent 0e9bd55 commit f90fa86
Showing 1 changed file with 0 additions and 20 deletions.
20 changes: 0 additions & 20 deletions spark/src/main/scala/geotrellis/spark/join/VectorJoin.scala
Expand Up @@ -73,24 +73,4 @@ object VectorJoin {
new FilteredCartesianRDD(sc, _pred, metapred, left, metaleft, right, metaright)
}

/**
* Perform the vector join operation over an RDD[L] and and RDD[R],
* where both L and R are viewble as Geometry.
*
* @param left An RDD[L], where L is viewable as a Geometry
* @param right An RDD[R], where R is viewable as a Geometry
* @param pred A predicate which answers whether an L and an R should be joined
* @return An RDD of L-R pairs
*/
def naive[
L: ClassTag : ? => Geometry,
R: ClassTag : ? => Geometry
](
left: RDD[L],
right: RDD[R],
pred: (Geometry, Geometry) => Boolean
)(implicit sc: SparkContext): RDD[(L, R)] =
left.cartesian(right)
.filter({ case (left: L, right: R) => pred(left, right) })

}

0 comments on commit f90fa86

Please sign in to comment.