1

I understand that its possible to do stateless aggregation using mapGroups and flatMapGroups API in Spark 2.x+. I want to use aggregate queries on a streaming registered temporary view. Is there any way to do the same using spark.sql(" ... ") ?

PS: I've checked this

Chitral Verma
  • 2,695
  • 1
  • 17
  • 29
  • Does this answer your question? [How to define and use a User-Defined Aggregate Function in Spark SQL?](https://stackoverflow.com/questions/32100973/how-to-define-and-use-a-user-defined-aggregate-function-in-spark-sql) – 10465355 Nov 26 '19 at 12:17

0 Answers0