Thanks. I know reimplementing windowing myself will work but that's a very bad
last resort.
I believe it is a very reasonable request. But since someone else has already
filed a Jira and it was closed as Won't Fix[1], I won't bother refiling it
again. I'll try something else first.
[1]
https:
Hi,
There is a discussion about this before, you can take a look at it[1].
Best, Hequn
[1]
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-implementation-of-aggregate-function-using-a-ProcessFunction-td23473.html#a23531
On Thu, May 9, 2019 at 5:14 AM an0 wrote:
>
I want to use ProcessWindowFunction.Context#globalState in my window function.
But I don't want to apply ProcessWindowFunction directly to my WindowedStream
because I don't want to buffer all the elements of each window. Currently I'm
using WindowedStream#aggregate(AggregateFunction, ProcessWind
