flink： sortPartition(0， Order.ASCENDING ) 错误： "not found: value Order"

Question

我正在运行以下代码并获得"error: not found: value Order"我想不出一个原因。我做错了什么?

版本: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

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

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