Sorry for the late response. MapState is currently only support as keyed state but not as operator state. If you want to create a keyed MapState the object should be created using a MapStateDescriptor in the open() method via the RuntimeContext.
2018-01-16 1:54 GMT+01:00 Boris Lublinsky <boris.lublin...@lightbend.com>: > Any response to this? > > List State is created using > > checkpointedState = context.getOperatorStateStore.getListState > (checkPointDescriptor) > > But there is no similar APIs for MapState > > Boris Lublinsky > FDP Architect > boris.lublin...@lightbend.com > https://www.lightbend.com/ > > Begin forwarded message: > > *From: *Boris Lublinsky <boris.lublin...@lightbend.com> > *Subject: **Re: Questions about managed operator state* > *Date: *January 14, 2018 at 7:39:00 PM CST > *To: *Fabian Hueske <fhue...@gmail.com> > *Cc: *user <user@flink.apache.org> > > Thanks Fabian, > After I switched to var it compiles, but its not initialized. > > @transient private var currentModels : MapState[String, Model] = _ > > Assignes null to MapState. > Do I create an empty hashMap there? > > Boris Lublinsky > FDP Architect > boris.lublin...@lightbend.com > https://www.lightbend.com/ > > On Jan 14, 2018, at 11:09 AM, Fabian Hueske <fhue...@gmail.com> wrote: > > 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/ >> >> > > Begin forwarded message: > > *From: *Boris Lublinsky <boris.lublin...@lightbend.com> > *Subject: **Questions about managed operator state* > *Date: *January 13, 2018 at 7:39:09 PM CST > *To: *user <user@flink.apache.org> > > 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/ > > >
