data.foreachRDD { rdd =>
      rdd.foreachPartition { partitionedRecords =>
        val dao = new StreamDao(driver, url, user, password)
        partitionedRecords.foreach { row =>
        do dmthng
          }
        }
      }
class StreamDao(driver: String, url: String, user: String, password: String) extends Serializable {
  ConnectionPool.singleton(url,user,password)
  def save(messages: MSG) = {
    using(DB(ConnectionPool.borrow())) { db =>
      }
    }

  }
}