Sortierung mit Python Flink API

Question

Ich bin auf der Suche nach den Ergebnissen einer groupBy, aber sehe keinen unterstützten Weg, wie es mit Java/Scala ist. Ich denke, ich könnte den Iterator in Funktion zu einem reduce_group übergeben, aber das scheint klobig.

Answer 1

Sie sollten in der Lage sein, Ihre Gruppiert nach Aufruf

grouped_set.sort_group(0, Order.ASCENDING)