Я пытаюсь отфильтровать RDD, используя Set.
У меня есть RDD, который представляет собой массив объектов (Fruit: String, Value: Int, Color: String), которые я хочу отфильтровать с помощьюНабор, который содержит некоторое значение Fruit.
Когда я пытаюсь фильтровать, используя фильтр
val Fruits = Set("Orange","Banana","Strawberry")
<rddname>.filter(line => line.Fruit.contains(Fruits))
, я получаю сообщение об ошибке «Задача не сериализуема».Что это значит?
Я тоже пробовал
<rddname>.filter(line => Fruits(line.Fruit))
Та же ошибка