Skip to content

Commit

Permalink
Revert ParquetFunctionFactory.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
adeet1 committed Mar 26, 2024
1 parent 60f473a commit b8a5c0a
Showing 1 changed file with 2 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,15 +14,9 @@ import org.locationtech.geomesa.convert.avro.AvroPath
import org.locationtech.geomesa.convert2.transforms.Expression.LiteralString
import org.locationtech.geomesa.convert2.transforms.TransformerFunction.NamedTransformerFunction
import org.locationtech.geomesa.convert2.transforms.{Expression, TransformerFunction, TransformerFunctionFactory}
import org.locationtech.geomesa.fs.storage.parquet.io.{SimpleFeatureParquetSchemaV1, SimpleFeatureReadSupport}
import org.locationtech.geomesa.fs.storage.parquet.io.{SimpleFeatureParquetSchema, SimpleFeatureReadSupport}
import org.locationtech.jts.geom._

/**
* For parsing geometries from a GeoParquet file, the GeometryFunctionFactory class provides equivalent functionality.
*
* This class is kept for backwards compatibility with older Parquet file formats.
*/
@Deprecated
class ParquetFunctionFactory extends TransformerFunctionFactory {

override def functions: Seq[TransformerFunction] = geometries
Expand All @@ -48,7 +42,7 @@ class ParquetFunctionFactory extends TransformerFunctionFactory {
abstract class ParquetGeometryFn[T <: Geometry, U](name: String, path: AvroPath)
extends NamedTransformerFunction(Seq(name), pure = true) {

import SimpleFeatureParquetSchemaV1.{GeometryColumnX, GeometryColumnY}
import SimpleFeatureParquetSchema.{GeometryColumnX, GeometryColumnY}

override def apply(args: Array[AnyRef]): AnyRef = {
path.eval(args(0).asInstanceOf[GenericRecord]).collect {
Expand Down

0 comments on commit b8a5c0a

Please sign in to comment.