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
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 <
abhishsi@tetrationanalytics.com> wrote:

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

Mime
View raw message