Re: MapState Initializion

2018-01-16 Thread Fabian Hueske
Alternatively, you can also create a keyed MapState as context.getKeyedStateStore().getMapState() in CheckpointedFunction.initializeState(). 2018-01-16 9:58 GMT+01:00 Fabian Hueske : > Sorry for the late response. > > MapState is currently only support as keyed state but not as operator > state.

Re: MapState Initializion

2018-01-16 Thread Fabian Hueske
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 : > An

MapState Initializion

2018-01-15 Thread Boris Lublinsky
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: >