This is an automated email from the ASF dual-hosted git repository.
jiayu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/sedona.git
The following commit(s) were added to refs/heads/master by this push:
new 603f821c7 [DOCS] Fix spelling; rename file (#1605)
603f821c7 is described below
commit 603f821c77d405d20516a53ba60fe26bcd1ded6d
Author: John Bampton <[email protected]>
AuthorDate: Thu Sep 26 22:46:20 2024 +1000
[DOCS] Fix spelling; rename file (#1605)
---
...teWithinPartitons.scala => AggregateWithinPartitions.scala} | 2 +-
.../scala/org/apache/sedona/viz/sql/optVizOperatorTest.scala | 10 +++++++---
2 files changed, 8 insertions(+), 4 deletions(-)
diff --git
a/spark/common/src/main/scala/org/apache/sedona/viz/sql/operator/AggregateWithinPartitons.scala
b/spark/common/src/main/scala/org/apache/sedona/viz/sql/operator/AggregateWithinPartitions.scala
similarity index 99%
rename from
spark/common/src/main/scala/org/apache/sedona/viz/sql/operator/AggregateWithinPartitons.scala
rename to
spark/common/src/main/scala/org/apache/sedona/viz/sql/operator/AggregateWithinPartitions.scala
index 3ef49aaf8..9f4a69fc9 100644
---
a/spark/common/src/main/scala/org/apache/sedona/viz/sql/operator/AggregateWithinPartitons.scala
+++
b/spark/common/src/main/scala/org/apache/sedona/viz/sql/operator/AggregateWithinPartitions.scala
@@ -26,7 +26,7 @@ import org.apache.spark.sql.{DataFrame, Row}
import scala.collection.mutable
import scala.collection.mutable.ArrayBuffer
-object AggregateWithinPartitons {
+object AggregateWithinPartitions {
/**
* Run aggregation within each partition without incurring a data shuffle.
Currently support
diff --git
a/spark/common/src/test/scala/org/apache/sedona/viz/sql/optVizOperatorTest.scala
b/spark/common/src/test/scala/org/apache/sedona/viz/sql/optVizOperatorTest.scala
index f4ab6870a..6aa000105 100644
---
a/spark/common/src/test/scala/org/apache/sedona/viz/sql/optVizOperatorTest.scala
+++
b/spark/common/src/test/scala/org/apache/sedona/viz/sql/optVizOperatorTest.scala
@@ -18,7 +18,7 @@
*/
package org.apache.sedona.viz.sql
-import org.apache.sedona.viz.sql.operator.{AggregateWithinPartitons,
VizPartitioner}
+import org.apache.sedona.viz.sql.operator.{AggregateWithinPartitions,
VizPartitioner}
import org.apache.sedona.viz.sql.utils.{Conf, LineageDecoder}
import org.apache.spark.sql.functions.lit
import org.locationtech.jts.geom.Envelope
@@ -43,7 +43,11 @@ class optVizOperatorTest extends VizTestBase {
// Test aggregation within partitions
val result =
- AggregateWithinPartitons(newDf.withColumn("weight", lit(100.0)),
"pixel", "weight", "avg")
+ AggregateWithinPartitions(
+ newDf.withColumn("weight", lit(100.0)),
+ "pixel",
+ "weight",
+ "avg")
assert(result.rdd.getNumPartitions == secondaryPID)
// Test the colorize operator
@@ -71,7 +75,7 @@ class optVizOperatorTest extends VizTestBase {
assert(newDf.rdd.getNumPartitions == secondaryPID)
// Test aggregation within partitions
- val result = AggregateWithinPartitons(newDf, "pixel", "weight", "count")
+ val result = AggregateWithinPartitions(newDf, "pixel", "weight", "count")
assert(result.rdd.getNumPartitions == secondaryPID)
// Test the colorize operator
