Add Implicit Equalization Methods for RDDs

spark/src/main/scala/geotrellis/spark/equalization/Implicits.scala

@@ -0,0 +1,15 @@
+package geotrellis.spark.equalization
+
+import geotrellis.raster._
+import geotrellis.spark._
+
+import org.apache.spark.rdd.RDD
+
+
+object Implicits extends Implicits
+
+trait Implicits {
+  implicit class withRDDSinglebandEqualizationMethods[K, M](val self: RDD[(K, Tile)] with Metadata[M]) extends RDDSinglebandEqualizationMethods[K, M]
+
+  implicit class withRDDMultibandEqualizationMethods[K, M](val self: RDD[(K, MultibandTile)] with Metadata[M]) extends RDDMultibandEqualizationMethods[K, M]
+}

spark/src/main/scala/geotrellis/spark/equalization/RDDMultibandEqualizationMethods.scala

@@ -0,0 +1,17 @@
+package geotrellis.spark.equalization
+
+import geotrellis.raster._
+import geotrellis.raster.histogram.StreamingHistogram
+import geotrellis.spark._
+import geotrellis.util.MethodExtensions
+
+import org.apache.spark.rdd.RDD
+
+
+trait RDDMultibandEqualizationMethods[K, M] extends MethodExtensions[RDD[(K, MultibandTile)] with Metadata[M]] {
+  def equalize(): RDD[(K, MultibandTile)] with Metadata[M] =
+    RDDHistogramEqualization.multiband(self)
+
+  def equalize(histograms: Array[StreamingHistogram]): RDD[(K, MultibandTile)] with Metadata[M] =
+    RDDHistogramEqualization.multiband(self, histograms)
+}

spark/src/main/scala/geotrellis/spark/equalization/RDDSinglebandEqualizationMethods.scala

@@ -0,0 +1,17 @@
+package geotrellis.spark.equalization
+
+import geotrellis.raster._
+import geotrellis.raster.histogram.StreamingHistogram
+import geotrellis.spark._
+import geotrellis.util.MethodExtensions
+
+import org.apache.spark.rdd.RDD
+
+
+trait RDDSinglebandEqualizationMethods[K, M] extends MethodExtensions[RDD[(K, Tile)] with Metadata[M]] {
+  def equalize(): RDD[(K, Tile)] with Metadata[M] =
+    RDDHistogramEqualization.singleband(self)
+
+  def equalize(histogram: StreamingHistogram): RDD[(K, Tile)] with Metadata[M] =
+    RDDHistogramEqualization.singleband(self, histogram)
+}

spark/src/main/scala/geotrellis/spark/package.scala

@@ -38,6 +38,7 @@ package object spark
     extends buffer.Implicits
     with crop.Implicits
     with density.Implicits
+    with equalization.Implicits
     with filter.Implicits
     with join.Implicits
     with knn.Implicits