Deterministic Update

[rhashmi]

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

[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.