Hi guys, I got an exception like the following, when I tried to implement a user defined aggregation function.
Exception in thread "main" java.lang.UnsupportedOperationException: No Encoder found for Set[(scala.Long, scala.Long)] The Set[(Long, Long)] is a field in the case class which is the output type for the aggregation. Is there a workaround for this? Best Regards, Jerry
