Нижеприведенный расширенный класс 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 [Nothing], x $ 2: org.apache.flink.util.Collector [Nothing]): переопределение модуля def reduce (
