Как передать несколько аргументов при сопоставлении и фильтрации RDD?

#apache-spark #pyspark #rdd Вопрос: В настоящее время у меня есть эта строка для фильтрации и применения функции к RDD. data_to_update.rdd.map(find_differences).filter(lambda row: bool(row)) Я хочу изменить find_differences функцию, чтобы она также…

Продолжить чтениеКак передать несколько аргументов при сопоставлении и фильтрации RDD?