controlling the time in spark-streaming

be a common use case. TIA Ian -- Ian Holsman i...@holsman.com.au PH: + 61-3-9028 8133 / +1-(425) 998-7083

Re: I want to filter a stream by a subclass.

-ish way would be records.flatMap(_ match { case i: Int= Some(i) case _ = None }) -- Ian Holsman i...@holsman.com.au PH: + 61-3-9028 8133 / +1-(425) 998-7083