a guest Jan 20th, 2017 117 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
- val monthlyAggregation = spark.sql(
- SELECT count(*) BLA BLA BLA
- GROUP BY BLA BLA BLA
- val query = monthlyAggregation.writeStream
RAW Paste Data