Hi,

Does SparkSQL support time based windowing queries over streams like the
following one (from Intel/StreamingSQL):

«

sql(
  """    |SELECT t.word, COUNT(t.word)    |FROM (SELECT * FROM test)
OVER (WINDOW '9' SECONDS, SLIDE '3' SECONDS) AS t    |GROUP BY t.word
""".stripMargin)

»

What are my options to perform these kind of queries over streams of data?

Thanks.

Reply via email to