Re: How to create empty RDD

It worked Zhou. On Mon, Jul 6, 2015 at 10:43 PM, Wei Zhou wrote: > 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 ÐΞ€ρ@Ҝ (๏̯͡๏) : > >

Re: How to create empty RDD

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 ÐΞ€ρ@Ҝ (๏̯͡๏) : > I need to return an empty RDD of type > > val output: RDD[(DetailInputRecord, VI

Re: How to create empty RDD

This should work val output: RDD[(DetailInputRecord, VISummary)] = sc.paralellize(Seq.empty[(DetailInputRecord, VISummary)]) On Mon, Jul 6, 2015 at 5:11 PM, ÐΞ€ρ@Ҝ (๏̯͡๏) wrote: > I need to return an empty RDD of type > > val output: RDD[(DetailInputRecord, VISummary)] > > > > This does not wor

How to create empty RDD

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