Hi,
I was going through the Javadoc for CheckpointedFunction.java, it says that:
*         // get the state data structure for the per-key state
*         countPerKey = context.getKeyedStateStore().getReducingState(
*                 new ReducingStateDescriptor<>("perKeyCount", new 
AddFunction<>(), Long.class));
*
*         // get the state data structure for the per-key state
*         countPerPartition = context.getOperatorStateStore().getOperatorState(
*                 new ListStateDescriptor<>("perPartitionCount", Long.class));

OperatorStateStore would not be per-key state data structure since it applies 
to non-keyed state. 
Is my understanding correct here?
Thanks,
Chirag

Reply via email to