Jingsong Lee created FLINK-6620: ----------------------------------- Summary: Add KeyGroupCheckpointedOperator interface that works for checkpointing key-groups Key: FLINK-6620 URL: https://issues.apache.org/jira/browse/FLINK-6620 Project: Flink Issue Type: Improvement Components: DataStream API Reporter: Jingsong Lee Priority: Minor
[~aljoscha] We have discussed it on: https://issues.apache.org/jira/browse/BEAM-1393 {code} /** * This interface is used to checkpoint key-groups state. */ public interface KeyGroupCheckpointedOperator extends KeyGroupRestoringOperator{ /** * Snapshots the state for a given {@code keyGroupIdx}. * * <p>AbstractStreamOperator would call this hook in * AbstractStreamOperator.snapshotState() while iterating over the key groups. * @param keyGroupIndex the id of the key-group to be put in the snapshot. * @param out the stream to write to. */ void snapshotKeyGroupState(int keyGroupIndex, DataOutputStream out) throws Exception; } {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)