flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Till Rohrmann (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1277) Support sort order for coGroup inputs
Date Mon, 24 Nov 2014 16:53:12 GMT
Till Rohrmann created FLINK-1277:
------------------------------------

             Summary: Support sort order for coGroup inputs
                 Key: FLINK-1277
                 URL: https://issues.apache.org/jira/browse/FLINK-1277
             Project: Flink
          Issue Type: Improvement
            Reporter: Till Rohrmann


The current Java and Scala API lack the possibility to specify the sort order of the inputs
of coGroup. It would be nice to be able to specify them like on a grouped data set. The syntax
could look the following way

{code}
a.coGroup(b).sortFirst(0, Order.ASCENDING).sortSecond("id", Order.DESCENDING).where(1).equal(0).apply()
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message