y
persons other than the intended recipient(s) is prohibited. If you receive this
e-mail in error, please notify the sender by phone or email immediately and
delete it!
From: Robert Metzger [mailto:rmetz...@apache.org]
Sent: Friday, January 15, 2016 10:18 AM
To: user@flink.apache.org
Su
3,
> Managing Director: Bo PENG, Wanzhou MENG, Lifang CHEN
> Sitz der Gesellschaft: Düsseldorf, Amtsgericht Düsseldorf, HRB 56063,
> Geschäftsführer: Bo PENG, Wanzhou MENG, Lifang CHEN
> This e-mail and its attachments contain confidential information from HUAWEI,
> which is intended o
Hi Radu,
I'm sorry for the delayed response.
I'm not sure what the purpose of DataStream.global() actually is. I've
opened a JIRA to document or remove it:
https://issues.apache.org/jira/browse/FLINK-3240.
For getting the final metrics, you can just call ".timeWindowAll()",
without a ".global()"
Hi,
I am trying to compute some final statistics over a stream topology. For this I
would like to gather all data from all windows and parallel partitions into a
single/global window. Could you suggest a solution for this. I saw that the map
function has a ".global()" but I end up with the
