Дорогие друзья! Мы строили-строили и, наконец, построили. 27 апреля собираем практиков и энтузиастов Apache Spark у себя на Мансарде! Расскажем, как перевели (почти) все наши ETL и ML пайплайны на Spark и как переехали на вторую версию. Познакомимся и пообщаемся! https://rambler-co-e-org.timepad.ru/event/470664/
Возникали ли у кого проблемы в спарке версией <1.6 когда допустим case class Message(a:String) sealed trait Result case class Good(r:String) extends Result case class Bad(r:String) extends Result case class Exp(n:Int) extends Result stream:DStream[Result]
stram.flatmap { case Bad(a) => Some(a) case _ => _ }
Сваливалось бы в Some(a) в случае если Good и Bad , но не Exp