Re: ReduceFunction mechanism

2017-06-14 Thread nragon
just an fyi: currently i'm doing map -> keyby -> reduce which in fact could only be keyby -> reduce since reduce can have the map logic. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ReduceFunction-mechanism-tp13651p13740.

Re: ReduceFunction mechanism

2017-06-14 Thread nragon
e. Using a map before all this is a solution. I've never tried AggregateFunction, any examples? Thanks, Nuno -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ReduceFunction-mechanism-tp13651p13723.html Sent from the Apache Flink User

Re: ReduceFunction mechanism

2017-06-14 Thread Fabian Hueske
re same thread processing)? > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/ReduceFunction- > mechanism-tp13651p13679.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: ReduceFunction mechanism

2017-06-13 Thread nragon
processing)? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ReduceFunction-mechanism-tp13651p13679.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: ReduceFunction mechanism

2017-06-12 Thread Fabian Hueske
nragon : > Hi, > > Regarding ReduceFunction. > Is reduce() called when there is only one record for a given key? > > Thanks > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/ReduceFunction- > mechan

ReduceFunction mechanism

2017-06-12 Thread nragon
Hi, Regarding ReduceFunction. Is reduce() called when there is only one record for a given key? Thanks -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ReduceFunction-mechanism-tp13651.html Sent from the Apache Flink User Mailing List