wywołanie różnych i razem map rzuca NPE w bibliotekę iskier
Nie jestem pewien, czy jest to błąd, więc jeśli zrobisz coś takiego
// d:spark.RDD[String]
d.distinct().map(x => d.filter(_.equals(x)))
dostaniesz Java NPE. Jeśli jednak zrobiszcollect
natychmiast podistinct
, wszystko będzie dobrze.
ja używamiskra 0.6.1.