RichGroupReduceFunction的正确方法签名

Question

RichGroupReduceFunction的以下扩展类不编译。签名似乎与接口不匹配。我分不清其中的区别。

   class SPointReduce extends RichGroupReduceFunction[Int, Int] {
      override def reduce (
                                 values: Iterable[Int],
                                 out: Collector[Int]): Unit = {
        values.foreach {
          value: Int =>
            out.collect(value)
        }
      }
    }

编译器报告：

错误：（62，16）方法reduce不覆盖任何内容。注意：类SPointReduce的超类包含以下是名为reduce:def-reduce（x$1:Iterable[NNothing]，x$2:org.apache.flink.util.Collector[NNothing]）：单位超控def reduce（

Answer 1

覆盖RichGroupReduceFunction的reduce方法时，必须确保导入java.lang.Iterable。否则，您将得到上述错误。