def METHOD_NAME(self, wkt):
    geom = wkt_loads(wkt)
    schema = StructType().add("geom", GeometryType())
    returned_geom = TestGeometrySerde.spark.createDataFrame([(geom,)], schema).take(1)[0][0]
    assert geom.equals(returned_geom)
    # serialized by python, deserialized by scala
    returned_wkt = TestGeometrySerde.spark.createDataFrame([(geom,)], schema).selectExpr("ST_AsText(geom)").take(1)[0][0]
    assert wkt_loads(returned_wkt).equals(geom)
    # serialized by scala, deserialized by python
    schema = StructType().add("wkt", StringType())
    returned_geom = TestGeometrySerde.spark.createDataFrame([(wkt,)], schema).selectExpr("ST_GeomFromText(wkt)").take(1)[0][0]
    assert geom.equals(returned_geom)