You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@spark.apache.org by "shicheng31604@gmail.com" <sh...@gmail.com> on 2019/02/27 07:03:42 UTC
Fw: how to reset streaming state regularly
Hi all:
In Spark Streaming, I want to count some metrics by day, but in method "mapWithState", there is no API for this. Of course, I can achieve this by adding some time information to the record. However, I still want to use the spark API implementation . So, is there any direct or indirect API for this in spark? Or is there any better solution for this?
Thanks!
shicheng31604@gmail.com