[jira] [Created] (FLINK-1277) Support sort order for coGroup inputs

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1277) Support sort order for coGroup inputs

Shang Yuanchun (Jira)
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)