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)