You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by Deepak Sharma <de...@gmail.com> on 2016/05/23 15:14:16 UTC

How to map values read from test file to 2 different RDDs

Hi
I am reading a text file with 16 fields.
All the place holders for the values of this text file has been defined in
say 2 different case classes:
Case1 and Case2

How do i map values read from text file , so my function in scala should be
able to return 2 different RDDs , with each each RDD of these 2 different
cse class type?
E.g first 11 fields mapped to Case1 while rest 6 fields mapped to Case2
Any pointer here or code snippet would be really helpful.


-- 
Thanks
Deepak