Re: sorting groups

gt; I think i don't understand what a keySelector is > > > Thanks! > Michele > -- > *Da:* Fabian Hueske > *Inviato:* martedì 16 giugno 2015 23.43.03 > *A:* user@flink.apache.org > *Oggetto:* Re: sorting groups > >Hi, > > the error is rel

Re: sorting groups

m>> Inviato: martedì 16 giugno 2015 23.43.03 A: user@flink.apache.org<mailto:user@flink.apache.org> Oggetto: Re: sorting groups Hi, the error is related to the way you specify the grouping and the sorting key. The API is currently restricted in the way, that you can only use a key se

Re: sorting groups

e this? I think i don't understand what a keySelector is Thanks! Michele Da: Fabian Hueske Inviato: martedì 16 giugno 2015 23.43.03 A: user@flink.apache.org Oggetto: Re: sorting groups Hi, the error is related to the way you specify the grouping an

Re: sorting groups

Hi, the error is related to the way you specify the grouping and the sorting key. The API is currently restricted in the way, that you can only use a key selector function for the sorting key if you also used a selector function for the grouping key. In Scala the use of key selector functions is

sorting groups

Hi everybody, I am trying to sorting a grouped dataset, but i am getting this error: Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: Sorting on KeySelector keys only works with KeySelector grouping. at org.apache.flink.api.scala.GroupedDataSet.sortGroup(Gr