I had looked at that. If I have a set of saved word counts from previous run, and want to load that in the next run, what is the best way to do it?
I am thinking of hacking the Spark code and have an initial rdd in StateDStream, and use that in for the first time. On Fri, Sep 12, 2014 at 11:04 PM, qihong <qc...@pivotal.io> wrote: > there's no need to initialize StateDStream. Take a look at example > StatefulNetworkWordCount.scala, it's part of spark source code. > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/How-to-initialize-StateDStream-tp14113p14146.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: user-unsubscr...@spark.apache.org > For additional commands, e-mail: user-h...@spark.apache.org > >
