flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: How to group and sort the output of a join
Date Wed, 15 Oct 2014 14:08:38 GMT
Hi,
this should be possible with:

.groupBy("f0.f0").sortGroup("f1.f0")

Robert recently did some work to allow accessing nested tuple fields
and fields of objects using string expressions. For tuple fields you
use "f0", "f1" and so on and the dot is used to access nested fields.

Cheers,
Aljoscha

On Wed, Oct 15, 2014 at 3:53 PM, Martin Neumann <mneumann@spotify.com> wrote:
> Hej,
>
> After a join operation I end up with a Tuple2<Tuple10<...>Tuple2<...>>
I
> now want to group it on field 1 from the first inner Tuple and then sort it
> by field 1 in the 2nd inner tuple.
>
> How do I do that? I think I need to use the key extractor to get the
> correct field but sort does not take one.
>
> cheers Martin

Mime
View raw message