scala - flink：sortPartition（0，Order.ASCENDING）错误：“未找到：值订单”

Question

我正在运行以下代码并收到“错误：未找到：值订单”我无法找出原因。我究竟做错了什么？

版本：Flink v 0.9.1（hadoop 1）不使用 hadoop：本地执行 shell：scala shell

Scala-Flink> val data_avg = data_split.map{x=> ((x._1), (x._2._2/x._2._1))}.sortPartition(1, Order.ASCENDING).setParallelism(1)
<console>:16: error: not found: value Order
            val data_avg = data_split.map{x=> ((x._1), (x._2._2/x._2._1))}.sortPartition(0, Order.ASCENDING).setParallelism(1)

Answer 1

问题是枚举Order不是由 Flink 的 Scala shell 自动导入的。因此，您必须手动添加以下导入。

import org.apache.flink.api.common.operators.Order