def METHOD_NAME(self):
    point_csv_df = self.spark.read.format("csv").\
        option("delimiter", ",").\
        option("header", "false").\
        load(csv_point_input_location)
    point_csv_df.createOrReplaceTempView("pointtable")
    point_df = self.spark.sql("select ST_Point(cast(pointtable._c0 as Decimal(24,20)), cast(pointtable._c1 as Decimal(24,20))) as arealandmark from pointtable")
    assert point_df.count() == 1000