mapping JavaRDD to jdbc DataFrame

Hi, I'd like to use a JavaRDD containing parameters for an SQL query, and use SparkSQL jdbc to load data from mySQL. Consider the following pseudo code: JavaRDDString namesRdd = ... ; ... options.put(url, jdbc:mysql://mysql?user=usr); options.put(password, pass); options.put(dbtable, (SELECT *

Re: mapping JavaRDD to jdbc DataFrame

You can use applySchema On Mon, May 4, 2015 at 10:16 PM, Lior Chaga lio...@taboola.com wrote: Hi, I'd like to use a JavaRDD containing parameters for an SQL query, and use SparkSQL jdbc to load data from mySQL. Consider the following pseudo code: JavaRDDString namesRdd = ... ; ...