val monthlyAggregation = spark.sql(
    """
		SELECT count(*) BLA BLA BLA
        GROUP BY BLA BLA BLA
    """.stripMargin)

  val query = monthlyAggregation.writeStream
    .outputMode("complete")
    //.format("console")
    .format("jdbc")
    .start("jdbc:mysql://localhost:3306/ad_db?user=root&password=pass")