Hi all,

I was using JdbcRRD and signature for constructure was accepting a
function to get a DB connection. This is very useful to provide my own
connection handler.

I'm valuating to move to daraframe, but I cannot how to provide such
function and migrate my code. I want to use my own 'getConnection'
rather than provide connection details.

JdbcRDD(SparkContext sc,
       scala.Function0<java.sql.Connection> getConnection,
       .....,
to
 val df: DataFrame = hiveSqlContext.read.format("jdbc").options(options).load();

How this can be achieved?

Thanks!

Reply via email to