sedona.spark.register package

Submodules

sedona.spark.register.geo_registrator module

class sedona.spark.register.geo_registrator.PackageImporter

Bases: object

static import_jvm_lib(jvm) → bool

class sedona.spark.register.geo_registrator.SedonaRegistrator

Bases: object

__init__() → None

Method generated by attrs for class SedonaRegistrator.

classmethod register(spark: SparkSession)

classmethod registerAll(spark: SparkSession) → bool

This is the core of whole package, It uses py4j to run wrapper which takes existing SparkSession and register all User Defined Functions by Apache Sedona developers, for this SparkSession.

Parameters:

spark – pyspark.sql.SparkSession, spark session instance

Returns:

bool, True if registration was correct.

sedona.spark.register.java_libs module

class sedona.spark.register.java_libs.SedonaJvmLib(value)

Bases: Enum

Adapter = 'org.apache.sedona.sql.utils.Adapter'

AdapterWrapper = 'org.apache.sedona.python.wrapper.utils.PythonAdapterWrapper'

CircleRDD = 'org.apache.sedona.core.spatialRDD.CircleRDD'

Envelope = 'org.locationtech.jts.geom.Envelope'

EnvelopeAdapter = 'org.apache.sedona.python.wrapper.adapters.EnvelopeAdapter'

FileDataSplitter = 'org.apache.sedona.common.enums.FileDataSplitter'

GeoJsonReader = 'org.apache.sedona.core.formatMapper.GeoJsonReader'

GeoSerializerData = 'org.apache.sedona.python.wrapper.adapters.GeoSparkPythonConverter'

Geography = 'org.apache.sedona.common.geometryObjects.Geography'

GeometryAdapter = 'org.apache.sedona.python.wrapper.adapters.GeometryAdapter'

GridType = 'org.apache.sedona.core.enums.GridType'

IndexType = 'org.apache.sedona.core.enums.IndexType'

JoinParams = 'org.apache.sedona.python.wrapper.adapters.JoinParamsAdapter'

JoinQuery = 'org.apache.sedona.core.spatialOperator.JoinQuery'

KNNQuery = 'org.apache.sedona.core.spatialOperator.KNNQuery'

LineStringRDD = 'org.apache.sedona.core.spatialRDD.LineStringRDD'

Moran = 'org.apache.sedona.stats.autocorrelation.Moran'

PointRDD = 'org.apache.sedona.core.spatialRDD.PointRDD'

PolygonRDD = 'org.apache.sedona.core.spatialRDD.PolygonRDD'

PythonConverter = 'org.apache.sedona.python.wrapper.adapters.PythonConverter'

PythonRddToJavaRDDAdapter = 'org.apache.sedona.python.wrapper.adapters.PythonRddToJavaRDDAdapter'

RangeQuery = 'org.apache.sedona.core.spatialOperator.RangeQuery'

RawJvmIndexRDDSetter = 'org.apache.sedona.python.wrapper.adapters.RawJvmIndexRDDSetter'

RectangleRDD = 'org.apache.sedona.core.spatialRDD.RectangleRDD'

SedonaContext = 'org.apache.sedona.spark.SedonaContext'

SedonaSQLRegistrator = 'org.apache.sedona.sql.utils.SedonaSQLRegistrator'

ShapeFileReader = 'org.apache.sedona.core.formatMapper.shapefileParser.ShapefileReader'

SpatialObjectLoaderAdapter = 'org.apache.sedona.python.wrapper.adapters.SpatialObjectLoaderAdapter'

SpatialRDD = 'org.apache.sedona.core.spatialRDD.SpatialRDD'

StorageLevel = 'org.apache.spark.storage.StorageLevel'

StructuredAdapter = 'org.apache.spark.sql.sedona_sql.adapters.StructuredAdapter'

WkbReader = 'org.apache.sedona.core.formatMapper.WkbReader'

WktReader = 'org.apache.sedona.core.formatMapper.WktReader'

classmethod from_str(geo_lib: str) → SedonaJvmLib

st_aggregates = 'org.apache.spark.sql.sedona_sql.expressions.st_aggregates'

st_constructors = 'org.apache.spark.sql.sedona_sql.expressions.st_constructors'

st_functions = 'org.apache.spark.sql.sedona_sql.expressions.st_functions'

st_predicates = 'org.apache.spark.sql.sedona_sql.expressions.st_predicates'

Module contents