Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // StreamingJob.scala
- ...
- val filteredEvents = content
- .map(x => Event.toCaseClass(x))
- .filter(x => x.value == true)
- ...
- // Event.scala
- case class Event(
- id: String,
- value: Int,
- )
- object Event {
- implicit val formats = DefaultFormats
- def toCaseClass(str: String) =
- parse(str).extract[Event]
- }
Add Comment
Please, Sign In to add comment