Hi Boris, the CheckpointedRestoring interface was removed in Flink 1.4.0 (and deprecated in an earlier version). Unfortunately, the docs have not been updated accordingly. I'll open a JIRA to fix this. The replacements for CheckpointedRestoring are the CheckpointedFunction or ListCheckpointed interfaces (see [1]).
I think the compile error is caused because you define newModels as val and not as var. Best, Fabian [1] https://github.com/apache/flink/blob/release-1.3/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedRestoring.java 2018-01-14 2:39 GMT+01:00 Boris Lublinsky <boris.lublin...@lightbend.com>: > Documentation https://ci.apache.org/projects/flink/ > flink-docs-release-1.4/dev/stream/state/state.html#using- > managed-operator-state > Refers to CheckpointedRestoring interface. > *Which jar defines this interface - can’t find it* > > *Also documentation refers to *MapState<UK, UV>. Do you have any example > of creation of Map State. > For value State in Scala, I can do just do > > private var sum: ValueState[(Long, Long)] = _ > > But it does not work for MapState - > Error:(44, 53) unbound placeholder parameter > private val newModels : MapState[String, Model] = _ > > > Boris Lublinsky > FDP Architect > boris.lublin...@lightbend.com > https://www.lightbend.com/ > >
