Geospark - Ошибка создания PointRDD - InvalidParametersException: не найдено подходящего метода для данных типов - PullRequest
Новая
       18

Geospark - Ошибка создания PointRDD - InvalidParametersException: не найдено подходящего метода для данных типов

0 голосов
/ 08 мая 2020

Я работаю в записной книжке Jupyter с: spark 2.4.5 geospark 1.3.1

Я пытаюсь создать PointRDD - класс для хранения географических точек, таких как POINT ((1.234), (50.5678)). Код, который я использую, приведен ниже: 

user_location = PointRDD( \
    sparkContext=spark, \
    InputLocation='./data.csv', \
    Offset=2, \
    splitter=FileDataSplitter.CSV, \
    carryInputData=True, \
    newLevel=StorageLevel.MEMORY_ONLY
    )

Здесь находится конструктор класса: https://github.com/DataSystemsLab/GeoSpark/blob/master/python/geospark/core/SpatialRDD/point_rdd.py

Я получаю эту ошибку - независимо от того, какая комбинация параметров Я использую для отправки в конструктор класса: 

/opt/conda/lib/python3.7/site-packages/geospark/utils/meta.py in __call__(self, *args, **kwargs)
    122                         return method(*args, **kwargs)
    123 
--> 124             raise InvalidParametersException("No matching method for given types found")
    125 
    126         else:

InvalidParametersException: No matching method for given types found

Эта ошибка выдается классом geospark.utils.meta.py: https://github.com/DataSystemsLab/GeoSpark/blob/master/python/geospark/utils/meta.py

Я новинка во всем этом - ie python, scala / java jars - Я просто откусил больше, чем могу прожевать .. 

user_id      date                   latitude          longitude 
xxxxxxxxxxx,2019-05-23 08:54:27.25,53.401000976562500,-2.739659356962473

Любая помощь будет очень признательна.

Спасибо

...