Ярлык Spark getItemPython

Программы на Python
Ответить Пред. темаСлед. тема
Anonymous
 Ярлык Spark getItem

Сообщение Anonymous »

Я делаю в Spark sql следующее:

Код: Выделить всё

spark.sql("""
SELECT
data.data.location.geometry.coordinates[0]
FROM df""")
Это работает нормально, однако я не хочу использовать необработанный SQL, я использую API фреймов данных следующим образом:

Код: Выделить всё

df.select("data.data.location.geometry.coordinates[0]")
К сожалению, это не работает:

Код: Выделить всё

AnalysisException: [DATATYPE_MISMATCH.UNEXPECTED_INPUT_TYPE] Cannot resolve "data.data.location.geometry.coordinates[0]" due to data type mismatch: Parameter 2 requires the "INTEGRAL" type, however "0" has the type "STRING".;
'Project [data#680.data.location.geometry.coordinates[0] AS 0#697]
+- Relation [data#680,id#681,idempotencykey#682,source#683,specversion#684,type#685] json
Я знаю, что могу использовать API F.col и использовать getItem(0), но существует ли встроенный способ получить ярлык getItem?
'.' есть ли ярлык getField для нарезки массива?
Спасибо за понимание

Подробнее здесь: https://stackoverflow.com/questions/786 ... m-shortcut
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «Python»