Hi Abhishek, you can implement custom sources by implementing the SourceFunction or the ParallelSourceFunction interface and then calling StreamExecutionEnvironment.addSource.
At the moment, it is not possible to control manually or from a source function when to trigger a checkpoint. This is the responsibility of the CheckpointCoordinator. Cheers, Till On Tue, May 17, 2016 at 8:28 PM, Abhishek R. Singh < abhis...@tetrationanalytics.com> wrote: > Hi, > > Can we define custom sources in link? Control the barriers and (thus) > checkpoints at good watermark points? > > -Abhishek- >
