Re: reg JDBCRDD code

2014-12-09 Thread Deepa Jayaveer
dbc.PreparedStatement.setInternal( PreparedStatement.java:3735) com.mysql.jdbc.PreparedStatement.setLong( PreparedStatement.java:3751) Thanks Deepa From:Akhil Das To:Deepa Jayaveer Cc:"user@spark.apache.org" Date: 12/09/2014 09:30 PM Subject:

Re: reg JDBCRDD code

2014-12-09 Thread Akhil Das
edStatement.setLong( > *PreparedStatement.java:3751*) > > Thanks > Deepa > > > > From:Akhil Das > To:Deepa Jayaveer > Cc:"user@spark.apache.org" > Date:12/09/2014 09:30 PM > Subject:Re: reg JDBCRDD code &g

Re: reg JDBCRDD code

2014-12-09 Thread Deepa Jayaveer
"user@spark.apache.org" Date: 12/09/2014 09:30 PM Subject:Re: reg JDBCRDD code Hi Deepa, In Scala, You will do something like https://gist.github.com/akhld/ccafb27f098163bea622 With Java API's it will be something like https://gist.github.com/akhld/0d9299aafc981553bc

Re: reg JDBCRDD code

2014-12-09 Thread Akhil Das
Hi Deepa, In Scala, You will do something like https://gist.github.com/akhld/ccafb27f098163bea622 With Java API's it will be something like https://gist.github.com/akhld/0d9299aafc981553bc34 Thanks Best Regards On Tue, Dec 9, 2014 at 6:39 PM, Deepa Jayaveer wrote: > Hi All, > am new to Spar

reg JDBCRDD code

2014-12-09 Thread Deepa Jayaveer
Hi All, am new to Spark. I tried to connect to Mysql using Spark. want to write a code in Java but getting runtime exception. I guess that the issue is with the function0 and function1 objects being passed in JDBCRDD . I tried my level best and attached the code, can you please help us to fix