any shared variable to store start/end
time bcoz shared variable like accumulator are write only in task.
is there any solution on this.
Thanks
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Time-based-aggregation-in-Real-time-Spark-Streaming
3 1-12-2014:12:01
> 1-12-2014:12:03
> 1 y 3 1-12-2014:12:04
> 1-12-2014:12:06
>
> What is the best way to perform time based aggregation in spark.
> Kindly suggest.
>
> Thanks
>
> --
>
apache-spark-user-list.1001560.n3.nabble.com/Time-based-aggregation-in-Real-time-Spark-Streaming-tp20102.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
