Кто-нибудь, пожалуйста, дайте мне знать, как вызвать map и filter и другие dataframe функции на py4j.java_gateway.JavaObject
Я пытаюсь разобрать план выполнения, чтобы получить нижние таблицы иих местоположение.
plan = spark.sql("sELECT * FROM abc.view_aa limit 10")._jdf.queryExecution().executedPlan().collectLeaves()
plan.map(lambda x: x)
Ошибка
AttributeError: у объекта 'function' нет атрибута '_get_object_id'