Hi Chirag

I think the doc is outdated, the comments in CheckpointFuncion.java on master 
now[1] is `get the state data structure for the per-partition state`

[1] 
https://github.com/apache/flink/blob/00fe8a01192a523544d3868360a924863a69d8f8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java#L83

Best, Congxian
On Feb 15, 2019, 13:39 +0800, Chirag Dewan <chirag.dewa...@yahoo.in>, wrote:
> 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