Questions about managed operator state

Posted by Boris Lublinsky on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Questions-about-managed-operator-state-tp17772.html

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
[hidden email]
https://www.lightbend.com/