You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by rhashmi <ri...@hotmail.com> on 2017/06/08 04:44:10 UTC

Deterministic Update

Is there any possibility to trigger sink operator on completion of
checkpoint? 



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Deterministic-Update-tp13580.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Deterministic Update

Posted by Nico Kruber <ni...@data-artisans.com>.

yes - you need to implement the CheckpointedFunction interface.
(as an example: our BucketingSink uses this)

Nico

On Thursday, 8 June 2017 06:44:10 CEST rhashmi wrote:
> Is there any possibility to trigger sink operator on completion of
> checkpoint?
> 
> 
> 
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Determi
> nistic-Update-tp13580.html Sent from the Apache Flink User Mailing List
> archive. mailing list archive at Nabble.com.