Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/1668
For raw operator state, override
`AbstractStreamOperator::snapshotState(StateSnapshotContext context)` inside
your operator. Your implementation calls to super, then it can obtain the raw
stream via `context.getRawOperatorStateOutput()`. This stream works like a
normal output stream, except that you can also call
`stream.startNewPartition()`. This signals that a partition is started and
previous partitions are finalized/immutable. Partitions are the atomic units of
state redistribution, think of them as the indiviual elements in a
`ListCheckpointed` state.
For restoring, override
`AbstractStreamOperator::initializeState(StateInitializationContext context)`.
After calling super, `context.getRawOperatorStateInputs()` provides an iterable
with one input stream per partition that your operator should restore.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
