I userd val output: RDD[(DetailInputRecord, VISummary)] = sc.emptyRDD[(DetailInputRecord, VISummary)] to create empty RDD before. Give it a try, it might work for you too.
2015-07-06 14:11 GMT-07:00 ÐΞ€ρ@Ҝ (๏̯͡๏) <deepuj...@gmail.com>: > I need to return an empty RDD of type > > val output: RDD[(DetailInputRecord, VISummary)] > > > > This does not work > > val output: RDD[(DetailInputRecord, VISummary)] = new RDD() > > as RDD is abstract class. > > How do i create empty RDD ? > -- > Deepak > >
