the aggregation task through fold function + element
processing through window function.
Hope this helps!
Regards,
Anchit
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/apply-with-fold-and-window-function-tp10092p10110.html
Sent from
Hi,
this is a known bug: https://issues.apache.org/jira/browse/FLINK-3869.
I'm still hoping that we can get a workaround in for Flink 1.2. See my last
comment in the Jira Issue.
Cheers,
Aljoscha
On Mon, 14 Nov 2016 at 14:49 Stephan Epping
wrote:
> Hello,
>
> I
Hello,
I wondered if there is a particular reason for the window function to have
explicitly the same input/output type?
public SingleOutputStreamOperator apply(R initialValue, FoldFunction foldFunction, WindowFunction function)
for example (the following does not work):