Re: JDBC SQL Server RDD

2016-05-17 Thread Suresh Thalamati
What is the error you are getting ? At least on the main code line I see JDBCRDD is marked as private[sql]. Simple alternative might be to call sql server using data frame api , and get rdd from data frame. eg: val df =

Re: JDBC SQL Server RDD

2016-05-15 Thread Mich Talebzadeh
Hi, Which version of Spark are you using? Dr Mich Talebzadeh LinkedIn * https://www.linkedin.com/profile/view?id=AAEWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw * http://talebzadehmich.wordpress.com On 15 May

JDBC SQL Server RDD

2016-05-15 Thread KhajaAsmath Mohammed
Hi , I am trying to test sql server connection with JDBC RDD but unable to connect. val myRDD = new JdbcRDD( sparkContext, () => DriverManager.getConnection(sqlServerConnectionString) , "select CTRY_NA,CTRY_SHRT_NA from dbo.CTRY limit ?, ?", 0, 5, 1, r => r.getString("CTRY_NA") + ",