Checkpoint and restore states

[Jack Huang]

Hi all,

I am doing a simple word count example and want to checkpoint the
accumulated word counts. I am not having any luck getting the counts saved
and restored. Can someone help?

env.enableCheckpointing(1000)

env.setStateBackend(new MemoryStateBackend())


>  ...



inStream
>     .keyBy({s => s})
>
>
>
> *.mapWithState((in:String, count:Option[Int]) => {        val newCount =
> count.getOrElse(0) + 1        ((in, newCount), Some(newCount))    })*
>     .print()



Thanks,

Jack Huang