Hacky workaround for preventing bounds being calculated twice

adeet1 · May 30, 2024 · 2f15551 · 2f15551
1 parent 9a66066
commit 2f15551
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 1 deletion.
diff --git a/...src/main/scala/org/locationtech/geomesa/fs/storage/common/AbstractFileSystemStorage.scala b/...src/main/scala/org/locationtech/geomesa/fs/storage/common/AbstractFileSystemStorage.scala
@@ -384,6 +384,7 @@ object AbstractFileSystemStorage {
       val geom = feature.getDefaultGeometry.asInstanceOf[Geometry]
       if (geom != null) {
         bounds.expandToInclude(geom.getEnvelopeInternal)
+        println(s"Expanded bbox for $feature [$this]")
       }
     }
 

diff --git a/...src/main/scala/org/locationtech/geomesa/fs/storage/parquet/ParquetFileSystemStorage.scala b/...src/main/scala/org/locationtech/geomesa/fs/storage/parquet/ParquetFileSystemStorage.scala
@@ -81,7 +81,9 @@ object ParquetFileSystemStorage extends LazyLogging {
 
     override def write(f: SimpleFeature): Unit = {
       writer.write(f)
-      observer.write(f)
+      if (!observer.isInstanceOf[AbstractFileSystemStorage.MetadataObserver]) {
+          observer.write(f)
+      }
     }
     override def flush(): Unit = observer.flush()
     override def close(): Unit = {

diff --git a/...main/scala/org/locationtech/geomesa/fs/storage/parquet/io/SimpleFeatureWriteSupport.scala b/...main/scala/org/locationtech/geomesa/fs/storage/parquet/io/SimpleFeatureWriteSupport.scala
@@ -53,6 +53,7 @@ class SimpleFeatureWriteSupport extends WriteSupport[SimpleFeature] {
 
       // Expand the bounding box for each geometry
       (0 until numGeoms).foreach(i => bounds(i).expandToInclude(envelopes(i)))
+      println(s"Expanded bbox for $feature [$this]")
     }
 
     def getBoundingBoxes: Array[Envelope] = bounds