Documentation https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/state/state.html#using-managed-operator-state <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/
