Re: DataSet with Multiple reduce Actions

2018-06-28 Thread Fabian Hueske
-- > 发件人:Osian Hedd Hughes > 发送时间:2018年6月28日(星期四) 00:35 > 收件人:user > 主 题:DataSet with Multiple reduce Actions > > Hi, > > I am new to Flink, and I'd like to firstly use it to perform some in > memory aggregation in batch mode (in some months th

回复:DataSet with Multiple reduce Actions

2018-06-27 Thread Zhijiang(wangzhijiang999)
-- 发件人:Osian Hedd Hughes 发送时间:2018年6月28日(星期四) 00:35 收件人:user 主 题:DataSet with Multiple reduce Actions Hi, I am new to Flink, and I'd like to firstly use it to perform some in memory aggregation in batch mode (in some months

DataSet with Multiple reduce Actions

2018-06-27 Thread Osian Hedd Hughes
Hi, I am new to Flink, and I'd like to firstly use it to perform some in memory aggregation in batch mode (in some months this will be migrated to permanent streaming, hence the choice of Flink). For this, I can successfully create the complex key that I require using KeySelector & returning a ha