flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: custom sources
Date Thu, 19 May 2016 12:48:20 GMT
Hi Abhishek,

you can implement custom sources by implementing the SourceFunction or the
ParallelSourceFunction interface and then calling

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


On Tue, May 17, 2016 at 8:28 PM, Abhishek R. Singh <
abhishsi@tetrationanalytics.com> wrote:

> Hi,
> Can we define custom sources in link? Control the barriers and (thus)
> checkpoints at good watermark points?
> -Abhishek-

View raw message