package sample import java.sql.{Connection, DriverManager, ResultSet} import org.apache.spark.SparkContext import org.apache.spark.SparkConf import org.apache.spark.rdd.JdbcRDD object Invastigation { def main(args: Array[String]): Unit = { val conf = new SparkConf().setAppName("Invastigation") val context = new SparkContext(conf) val dbDriver = "com.mysql.jdbc.Driver" val dbUrl = "jdbc:mysql://loc
