spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tobias Pfeiffer <...@preferred.jp>
Subject Re: I want to filter a stream by a subclass.
Date Thu, 22 May 2014 01:02:03 GMT
On Thu, May 22, 2014 at 8:07 AM, Tathagata Das
<tathagata.das1565@gmail.com> wrote:
> records.filter { _.isInstanceOf[Orange] } .map { _.asInstanceOf[Orange] }

I think a Scala-ish way would be

records.flatMap(_ match {
  case i: Int=>
    Some(i)
  case _ =>
    None
})

Mime
View raw message