Pyspark: как разобрать список для getItem в dataframe? - PullRequest
1 голос
/ 07 апреля 2020

Если у меня есть список ниже:

x = ['record', 'box', 'tangle']

и я хочу отфильтровать свой фрейм данных sdt.printSchema()

name: string (nullable = true)
context: string (nullable = true)
timestamp: timestamp
record_content: map (nullable = true)
     key: string
     value: string (valueContainsNull = true)

Затем я использую фильтр ниже:

sdt.filter(col("record_content").getItem(x) == 'High')

Но я получил erorr belwo:

Py4JJavaError: Произошла ошибка при вызове o2501.apply. : java .lang.RuntimeException: неподдерживаемый класс литерального типа java .util.ArrayList [AvailabilityInfo.RcsNodeIdentityInfo.NodeIdReason, AvailabilityInfo.CppCoreNodeIdentityInfo.NodeIdReason]

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...