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 <mailto:boris.lublin...@lightbend.com> > https://www.lightbend.com/ > >> On Jan 14, 2018, at 11:09 AM, Fabian Hueske <fhue...@gmail.com >> <mailto: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 >> >> <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 >> <mailto: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 >> >> <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 <mailto:boris.lublin...@lightbend.com> >> https://www.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 > > <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 <mailto:boris.lublin...@lightbend.com> > https://www.lightbend.com/ >
