Hi Michele,
Flink supports coGroups on sorted inputs. If you have a ds1 = DataSet[(Key,
Value1)] and ds2 = DataSet[(Key, Value2)] you obtain a sorted coGroup for
example by:
ds1.coGroup(ds2).where(0).equalsTo(0).sortFirstGroup(1,
Order.ASCENDING).sortSecondGroup(1, Order.DESCENDING)
Cheers
Hi everybody, i need to execute a cogroup on sorted groups.
I explain it better: I have two datasets i.e. (key, value), I want to cogroup
on key and then the have both iterator sorted by value
how can i get it?
I know iterator should be collected to be sorted but i want to avoid it. what
happens
