У меня есть PipelinedRDD, который является подклассом RDD, но я не могу применить ни одну из функций его родительского класса. Я получаю AttributeError.
Я получаю следующую ошибку:
AttributeError: у объекта PipelinedRDD нет атрибута toList
pipelined_rdd = df.filter(col("id").between(lower_bound, upper_bound)).rdd.map(lambda x: x[0])
pipelined_rdd_list = pipelined_rdd.toList
Я получаю следующую ошибку:
AttributeError: у объекта 'PipelinedRDD' нет атрибута 'toList'