What is the best way in Scala/Spark to match lines from a stream to a selection of case classes.
Thinking: Schema on Read. This would be after an RDD is split.
Looking to handle a few different types of records, very similar, but with some different fields.