You can directly use filter on a Dataframe
On 2 Jul 2015 12:15, "Ashish Soni" <asoni.le...@gmail.com> wrote:
> Hi All ,
>
> I have an DataFrame Created as below
>
> options.put("dbtable", "(select * from user) as account");
> DataFrame accountRdd =
> sqlContext.read().format("jdbc").options(options).load();
>
> and i have another RDD which contains login name and i want to find the
> userid from above DF RDD and return it
>
> Not sure how can i do that as when i apply a map function and say filter
> on DF i get Null pointor exception.
>
> Please help.
>
>
>
