Scala JdbcRDD MySQL Connector

scala-mysql-jdbc-spark

val rdd = new org.apache.spark.rdd.JdbcRDD(
        ssc.sparkContext,
        () => {
          Class.forName("org.mysql.Driver")
          DriverManager.getConnection("jdbc:mysql://localhost:3306/sigmoid"), "akhld", "pass")
        },
        "SELECT * FROM logs WHERE ? <= id AND id <= ?",
        0,  1000, 10,
        row => {

          var new_map: Map[String, Any] = Map()

          for(key <- tmp_schema){
            try{
              new_map += key._1 -> row.getString(key._1)
            }catch{ case e: Exception =>
              println("Exception!! => " + e)
              new_map += key._1 -> ""
            }
          }
          new_map.toList
        }
      )