Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
Date: Sun, 21 May 2017 10:29:04 +0000 (UTC)
From: "Aljoscha Krettek (JIRA)" <jira@apache.org>
To: issues@flink.apache.org
Message-ID: <JIRA.13073011.1495085032000.257298.1495362544893@Atlassian.JIRA>
In-Reply-To: <JIRA.13073011.1495085032000@Atlassian.JIRA>
References: <JIRA.13073011.1495085032000@Atlassian.JIRA> <JIRA.13073011.1495085032809@jira-lw-us.apache.org>
Subject: [jira] [Commented] (FLINK-6620) Add KeyGroupCheckpointedOperator
 interface that works for checkpointing key-groups
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable
archived-at: Sun, 21 May 2017 10:29:10 -0000


    [ https://issues.apache.org/jira/browse/FLINK-6620?page=3Dcom.atlassian=
.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D1601=
8778#comment-16018778 ]=20

Aljoscha Krettek commented on FLINK-6620:
-----------------------------------------

[~lzljs3620320] Unfortunately I'm very busy last week and the next week (Ap=
acheCon and Strata London) so I'm very slow to respond to anything. Thanks =
for opening this issue! =F0=9F=98=83

[~srichter] What do you think about this? We've had an interface like this =
for a while in Beam to support writing custom things along with the timers =
in key-grouped state.

> Add KeyGroupCheckpointedOperator interface that works for checkpointing k=
ey-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/brows=
e/BEAM-1393
> {code}
> /**
>  * This interface is used to checkpoint key-groups state.
>  */
> public interface KeyGroupCheckpointedOperator extends KeyGroupRestoringOp=
erator{
>   /**
>    * 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 snapsh=
ot.
>    * @param out the stream to write to.
>    */
>   void snapshotKeyGroupState(int keyGroupIndex, DataOutputStream out) thr=
ows Exception;
> }
> {code}


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)