Hello all,
I am working a problem that requires us to create different set of JavaRDD
based on different input arguments. We are getting following error when we try
to use a factory to create JavaRDD. Error message is clear but I am wondering
is there any workaround.
Question:
How to create
…
>
> }
>
> });
>
> return featureScoreRDD;
>
> }
>
>
>
> }
>
>
>
> Thanks again for all your help and advice.
>
>
>
> Regards,
>
>
>
> Rac
Hello Rachana,
The easiest way would be to start with creating a 'parent' JavaRDD and run
different filters (based on different input arguments) to create respective
'child' JavaRDDs dynamically.
Notice that the creation of these children RDDs is handled by the
application driver.
Hope this
