使用Python Flink API进行排序



我想对groupBy的结果进行排序,但没有看到Java/Scala支持的方法。我想我可以在传递给reduce_group的函数中实现迭代器,但这似乎很笨拙。

您应该能够通过调用对分组集进行排序

    grouped_set.sort_group(0, Order.ASCENDING)

相关内容

  • 没有找到相关文章

最新更新