Hi Stephan,
> On Nov 2, 2016, at 3:04am, Stephan Ewen 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
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 wrote:
> Hi Ken!
>
> It may not be obvious, so here is a bit of background:
>
> The timers that are used in the FlatMapFu
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 y
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/project
