1 /***********************************************************************
2  * Copyright (c) 2013-2024 Commonwealth Computer Research, Inc.
3  * All rights reserved. This program and the accompanying materials
4  * are made available under the terms of the Apache License, Version 2.0
5  * which accompanies this distribution and is available at
6  * http://www.opensource.org/licenses/apache2.0.php.
7  ***********************************************************************/
8 
9 package org.locationtech.geomesa.spark.jts.encoders
10 
11 import org.apache.spark.sql.Encoder
12 import org.apache.spark.sql.catalyst.encoders.ExpressionEncoder
13 import org.locationtech.jts.geom._
14 
15 /** Encoders are Spark SQL's mechanism for converting a JVM type into a Catalyst representation.
16  * They are fetched from implicit scope whenever types move beween RDDs and Datasets. Because each
17  * of the types supported below has a corresponding UDT, we are able to use a standard Spark Encoder
18  * to construct these implicits. */
19 trait SpatialEncoders {
20   implicit def jtsGeometryEncoder: Encoder[Geometry] = ExpressionEncoder()
21   implicit def jtsPointEncoder: Encoder[Point] = ExpressionEncoder()
22   implicit def jtsLineStringEncoder: Encoder[LineString] = ExpressionEncoder()
23   implicit def jtsPolygonEncoder: Encoder[Polygon] = ExpressionEncoder()
24   implicit def jtsMultiPointEncoder: Encoder[MultiPoint] = ExpressionEncoder()
25   implicit def jtsMultiLineStringEncoder: Encoder[MultiLineString] = ExpressionEncoder()
26   implicit def jtsMultiPolygonEncoder: Encoder[MultiPolygon] = ExpressionEncoder()
27   implicit def jtsGeometryCollectionEncoder: Encoder[GeometryCollection] = ExpressionEncoder()
28 }