This is an automated email from the ASF dual-hosted git repository. zkaoudi pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/wayang.git
commit 42e2fa6dce36c7f399d3a96850379ce177809526 Merge: e726cdfae e75b6eda6 Author: Zoi Kaoudi <[email protected]> AuthorDate: Mon May 4 09:18:48 2026 +0200 Merge pull request #699 from Spatial-Data-MP/main Extend Wayang with spatial operators pom.xml | 1 + .../scala/org/apache/wayang/api/DataQuanta.scala | 80 ++- .../org/apache/wayang/api/DataQuantaBuilder.scala | 96 +++- .../java/org/apache/wayang/api/JavaApiTest.java | 16 + .../wayang/api/sql/sources/fs/CsvRowConverter.java | 1 + wayang-benchmark/pom.xml | 5 + .../apache/wayang/apps/spatial/SpatialFilter.java | 73 +++ .../wayang/apps/spatial/SpatialFilterPostgis.java | 74 +++ .../apache/wayang/apps/spatial/SpatialJoin.java | 69 +++ .../wayang/apps/spatial/SpatialJoinPostgis.java | 102 ++++ wayang-commons/wayang-basic/pom.xml | 2 +- .../wayang/basic/operators/GeoJsonFileSource.java | 45 ++ .../basic/operators/SpatialFilterOperator.java | 87 ++++ .../basic/operators/SpatialJoinOperator.java | 112 ++++ .../wayang/core/api/spatial/SpatialGeometry.java | 42 ++ .../wayang/core/api/spatial/SpatialPredicate.java | 31 ++ .../apache/wayang/jdbc/execution/JdbcExecutor.java | 26 +- .../wayang/spark/platform/SparkPlatform.java | 1 + wayang-plugins/pom.xml | 1 + wayang-plugins/wayang-spatial/pom.xml | 180 +++++++ .../java/org/apache/wayang/spatial/Spatial.java | 189 +++++++ .../apache/wayang/spatial/data/WayangGeometry.java | 271 ++++++++++ .../spatial/function/JtsSpatialPredicate.java | 86 +++ .../apache/wayang/spatial/mapping/Mappings.java | 62 +++ .../mapping/java/GeoJsonFileSourceMapping.java | 58 +++ .../spatial/mapping/java/SpatialFilterMapping.java | 58 +++ .../spatial/mapping/java/SpatialJoinMapping.java | 56 ++ .../mapping/postgres/SpatialFilterMapping.java | 58 +++ .../mapping/postgres/SpatialJoinMapping.java | 59 +++ .../mapping/spark/SpatialFilterMapping.java | 58 +++ .../spatial/mapping/spark/SpatialJoinMapping.java | 65 +++ .../operators/java/JavaGeoJsonFileSource.java | 146 ++++++ .../operators/java/JavaSpatialFilterOperator.java | 109 ++++ .../operators/java/JavaSpatialJoinOperator.java | 138 +++++ .../operators/jdbc/JdbcSpatialFilterOperator.java | 78 +++ .../operators/jdbc/JdbcSpatialJoinOperator.java | 75 +++ .../postgres/PostgresSpatialFilterOperator.java | 60 +++ .../postgres/PostgresSpatialJoinOperator.java | 53 ++ .../spark/SparkSpatialFilterOperator.java | 186 +++++++ .../operators/spark/SparkSpatialJoinOperator.java | 186 +++++++ .../org/apache/wayang/api/JavaApiSpatialTest.java | 574 +++++++++++++++++++++ .../wayang/spatial/data/WayangGeometryTest.java | 221 ++++++++ .../PostgresSpatialIntegrationTest.java | 284 ++++++++++ .../java/JavaSpatialFilterOperatorTest.java | 174 +++++++ .../java/JavaSpatialJoinOperatorTest.java | 194 +++++++ .../jdbc/JdbcSpatialFilterOperatorTest.java | 177 +++++++ .../jdbc/JdbcSpatialJoinOperatorTest.java | 195 +++++++ .../spark/SparkSpatialFilterOperatorTest.java | 190 +++++++ .../spark/SparkSpatialJoinOperatorTest.java | 172 ++++++ .../apache/wayang/spatial/test/HsqldbPlatform.java | 42 ++ .../wayang/spatial/test/HsqldbTableSource.java | 50 ++ .../src/test/resources/geojson-sample.json | 33 ++ .../wayang-spatial/src/test/resources/uniform.csv | 114 ++++ .../resources/wayang-hsqldb-defaults.properties | 21 + 54 files changed, 5520 insertions(+), 16 deletions(-)
