daily pastebin goal
21%
SHARE
TWEET

Untitled

a guest Jan 20th, 2017 117 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1.   val monthlyAggregation = spark.sql(
  2.     """
  3.         SELECT count(*) BLA BLA BLA
  4.         GROUP BY BLA BLA BLA
  5.     """.stripMargin)
  6.  
  7.   val query = monthlyAggregation.writeStream
  8.     .outputMode("complete")
  9.     //.format("console")
  10.     .format("jdbc")
  11.     .start("jdbc:mysql://localhost:3306/ad_db?user=root&password=pass")
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand