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:
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
