There is already an open PR for fixing those Javadoc issues (along with
some other issues): https://github.com/apache/flink/pull/2715

On Wed, 2 Nov 2016 at 11:04 Stephan Ewen <se...@apache.org> wrote:

> Hi Ken!
>
> It may not be obvious, so here is a bit of background:
>
> The timers that are used in the FlatMapFunction are scoped by key. We
> thought that this is how they are mainly useful - that's why you need to
> define keys to use them.
> I think the docs are in error, thanks for pointing that out.
>
> In your use case, do you need timers without keys, or only access to the
> current processing/event time?
>
> Best,
> Stephan
>
>
> On Wed, Nov 2, 2016 at 1:59 AM, Ken Krugler <kkrugler_li...@transpac.com>
> wrote:
>
> I’m curious why it seems like a TimelyFlatMapFunction can’t be used with a
> regular DataStream, but it can be used with a KeyedStream.
>
> Or maybe I’m missing something obvious (this is with 1.2-SNAPSHOT, pulled
> today).
>
> Also the documentation of TimelyFlatMapFunction (
> https://ci.apache.org/projects/flink/flink-docs-master/api/java/index.html?org/apache/flink/streaming/api/functions/TimelyFlatMapFunction.html)
> shows using it with a DataStream.flatMap(xxx) call.
>
> Thanks,
>
> — Ken
>
> --------------------------
> Ken Krugler
> +1 530-210-6378
> http://www.scaleunlimited.com
> custom big data solutions & training
> Hadoop, Cascading, Cassandra & Solr
>
>
>
>
>

Reply via email to