Deterministic Update

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Deterministic Update

rhashmi
Is there any possibility to trigger sink operator on completion of checkpoint?
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Deterministic Update

Nico Kruber
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.


signature.asc (201 bytes) Download Attachment
Loading...