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
[EMAIL PROTECTED]
https://www.lightbend.com/
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB