Re: Does flink support groupByKey([numTasks])

2015-09-13 Thread Fabian Hueske
, 12. Sep. 2015 um > 05:53 Uhr: > > > Hi > > > > Now i am considering migrate Sparkstreaming case to Flink for comparing > > performance. > > > > Does flink support groupByKey([numTasks]) ,When called on a dataset of > (K, > > V) pairs, returns a da

Re: Does flink support groupByKey([numTasks])

2015-09-12 Thread Martin Liesenberg
to Flink for comparing > performance. > > Does flink support groupByKey([numTasks]) ,When called on a dataset of (K, > V) pairs, returns a dataset of (K, Iterable) pairs. > If it is not exist, how to use groupBy() to implement the same function? > > > > -- > View this

Does flink support groupByKey([numTasks])

2015-09-11 Thread Liang Chen
Hi Now i am considering migrate Sparkstreaming case to Flink for comparing performance. Does flink support groupByKey([numTasks]) ,When called on a dataset of (K, V) pairs, returns a dataset of (K, Iterable) pairs. If it is not exist, how to use groupBy() to implement the same function