Adds ST_SIMPLIFY geo spatial function

docs/changelog/136309.yaml

@@ -0,0 +1,6 @@
+pr: 136309
+summary: Adds ST_SIMPLIFY geospatial function
+area: ES|QL
+type: enhancement
+issues:
+ - 44747

docs/reference/query-languages/esql/_snippets/lists/spatial-functions.md

@@ -13,3 +13,4 @@
 * [`ST_GEOTILE`](../../functions-operators/spatial-functions.md#esql-st_geotile) {applies_to}`stack: preview` {applies_to}`serverless: preview`
 * [`ST_GEOHEX`](../../functions-operators/spatial-functions.md#esql-st_geohex) {applies_to}`stack: preview` {applies_to}`serverless: preview`
 * [`ST_GEOHASH`](../../functions-operators/spatial-functions.md#esql-st_geohash) {applies_to}`stack: preview` {applies_to}`serverless: preview`
+* [`ST_SIMPLIFY`](../../functions-operators/spatial-functions.md#esql-st_simplify) {applies_to}`stack: preview` {applies_to}`serverless: preview`

docs/reference/query-languages/esql/functions-operators/spatial-functions.md

@@ -59,3 +59,6 @@ mapped_pages:
 
 :::{include} ../_snippets/functions/layout/st_geohash.md
 :::
+
+:::{include} ../_snippets/functions/layout/st_simplify.md
+:::

x-pack/plugin/esql-core/build.gradle

@@ -15,6 +15,7 @@ base {
 
 dependencies {
   api project(path: xpackModule('mapper-version'))
+  api "org.locationtech.jts:jts-core:${versions.jts}"
   testImplementation project(':test:framework')
   testImplementation(testArtifact(project(xpackModule('core'))))
 }

x-pack/plugin/esql-core/licenses/jts-core-LICENSE.txt

@@ -0,0 +1,31 @@
+Eclipse Distribution License - v 1.0
+
+Copyright (c) 2007, Eclipse Foundation, Inc. and its licensors.
+
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+  Redistributions of source code must retain the above copyright notice, this
+  list of conditions and the following disclaimer.
+
+  Redistributions in binary form must reproduce the above copyright notice,
+  this list of conditions and the following disclaimer in the documentation
+  and/or other materials provided with the distribution.
+
+  Neither the name of the Eclipse Foundation, Inc. nor the names of its
+  contributors may be used to endorse or promote products derived from this
+  software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
+ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+

x-pack/plugin/esql-core/licenses/jts-core-NOTICE.txt

@@ -0,0 +1 @@
+

x-pack/plugin/esql-core/src/main/java/org/elasticsearch/xpack/esql/core/util/SpatialCoordinateTypes.java

@@ -12,10 +12,19 @@
 import org.apache.lucene.util.BytesRef;
 import org.elasticsearch.geometry.Geometry;
 import org.elasticsearch.geometry.Point;
+import org.elasticsearch.geometry.Rectangle;
 import org.elasticsearch.geometry.utils.GeographyValidator;
 import org.elasticsearch.geometry.utils.GeometryValidator;
 import org.elasticsearch.geometry.utils.WellKnownBinary;
 import org.elasticsearch.geometry.utils.WellKnownText;
+import org.locationtech.jts.geom.Coordinate;
+import org.locationtech.jts.geom.GeometryFactory;
+import org.locationtech.jts.geom.LinearRing;
+import org.locationtech.jts.geom.Polygon;
+import org.locationtech.jts.geom.impl.CoordinateArraySequence;
+import org.locationtech.jts.io.ParseException;
+import org.locationtech.jts.io.WKTReader;
+import org.locationtech.jts.io.WKTWriter;
 
 import java.nio.ByteOrder;
 
@@ -125,4 +134,31 @@ public String wkbToWkt(BytesRef wkb) {
     public Geometry wkbToGeometry(BytesRef wkb) {
         return WellKnownBinary.fromWKB(validator(), false, wkb.bytes, wkb.offset, wkb.length);
     }
+
+    public org.locationtech.jts.geom.Geometry wkbToJtsGeometry(BytesRef wkb) throws ParseException, IllegalArgumentException {
+        String wkt = wkbToWkt(wkb);
+        if (wkt.startsWith("BBOX")) {
+            Geometry geometry = WellKnownBinary.fromWKB(GeometryValidator.NOOP, true, wkb.bytes, wkb.offset, wkb.length);
+            if (geometry instanceof Rectangle rect) {
+                var bottomLeft = new Coordinate(rect.getMinX(), rect.getMinY());
+                var bottomRight = new Coordinate(rect.getMaxX(), rect.getMinY());
+                var topRight = new Coordinate(rect.getMaxX(), rect.getMaxY());
+                var topLeft = new Coordinate(rect.getMinX(), rect.getMaxY());
+
+                var coordinates = new Coordinate[] { bottomLeft, bottomRight, topRight, topLeft, bottomLeft };
+                var geomFactory = new GeometryFactory();
+                var linearRing = new LinearRing(new CoordinateArraySequence(coordinates), geomFactory);
+                return new Polygon(linearRing, null, geomFactory);
+            }
+        }
+        WKTReader reader = new WKTReader();
+        return reader.read(wkt);
+    }
+
+    public BytesRef jtsGeometryToWkb(org.locationtech.jts.geom.Geometry jtsGeometry) {
+        WKTWriter writer = new WKTWriter();
+        String wkt = writer.write(jtsGeometry);
+        return wktToWkb(wkt);
+    }
+
 }