Hi Stephen,
Chesney was right, you will have to use a more complex version of the
window processing function.
Perhaps your goal can be achieve by this specific function with incremental
aggregation [1]. If not you can always use the regular process window
function [2].
Both of these methods have a
On Sun, 10 Feb 2019 at 09:48, Chesnay Schepler wrote:
> There are also versions of WindowedStream#aggregate that accept an
> additional WindowFunction/ProcessWindowFunction, which do have access to
> the key via apply()/process() respectively. These functions are called
> post aggregation.
>
Coo
There are also versions of WindowedStream#aggregate that accept an
additional WindowFunction/ProcessWindowFunction, which do have access to
the key via apply()/process() respectively. These functions are called
post aggregation.
On 08.02.2019 18:24, stephen.alan.conno...@gmail.com wrote:
If I
If I write my aggregation logic as a WindowFunction then I get access to the
key as the first parameter in WindowFunction.apply(...) however the Javadocs
for calling WindowedStream.apply(WindowFunction) state:
> Note that this function requires that all data in the windows is buffered
> until t
