If you want to connect to DB in program, you can use JdbcRDD ( https://github.com/apache/spark/blob/master/core/src/main/scala/org/apache/spark/rdd/JdbcRDD.scala )
2014-07-24 18:32 GMT+08:00 Yosi Botzer <yosi.bot...@gmail.com>: > Hi, > > I am using the Java api of Spark. > > I wanted to know if there is a way to run some code in a manner that is > like the setup() and cleanup() methods of Hadoop Map/Reduce > > The reason I need it is because I want to read something from the DB > according to each record I scan in my Function, and I would like to open > the DB connection only once (and close it only once). > > Thanks >
