xxx in ‘Anonymous class derived from xxx clashes with ‘call(T)‘ in xxx attempting to use incompati

完整报错如下:

'call(Tuple2<Long, Row>)' in 'Anonymous class derived from org.apache.spark.api.java.function.PairFlatMapFunction'

clashes with 'call(T)' in 'org.apache.spark.api.java.function.PairFlatMapFunction';

attempting to use incompatible return type

点击PairFlatMapFunction源码:

@FunctionalInterface
public interface PairFlatMapFunction<T, K, V> extends Serializable {Iterator<Tuple2<K, V>> call(T t) throws Exception;
}

发现要求返回iterator

原因：

两处不一致:

①return处与public后面的类型不一致。

②Tuple2<String,Row>应该改成Tuple2<String,Row>

解决方案如下:

    private static PairFlatMapFunction<Tuple2<Long,Row>, String, Row>func7= new PairFlatMapFunction<Tuple2<Long,Row>, String, Row>() {private static final long serialVersionUID = 1L;public Iterable<Tuple2<String, Row>> call(Tuple2<Long, Row> tuple) throws Exception
{Random random = new Random();List<Tuple2<String, Row>> list = new ArrayList<Tuple2<String, Row>>();for(int i = 0; i < 100; i++) {list.add(new Tuple2<String, Row>(i + "_" + tuple._1, tuple._2));}return list;}
};

改成:

private static  PairFlatMapFunction<Tuple2<String,Row>, String, Row>  func7 = new PairFlatMapFunction<Tuple2<String,Row>, String, Row>(){private static final long serialVersionUID = 1L;
//    @Overridepublic Iterator<Tuple2<String, Row>> call(Tuple2<String, Row> tuple) throws Exception
{Random random = new Random();List<Tuple2<String, Row>> list = new ArrayList<Tuple2<String, Row>>();for(int i = 0; i < 100; i++){list.add(new Tuple2<String, Row>(i + "_" + tuple._1, tuple._2));}return list.iterator();}};

xxx in ‘Anonymous class derived from xxx clashes with ‘call(T)‘ in xxx attempting to use incompati相关推荐

‘getCurrentWatermark()‘ in ‘Anonymous class derived from xxx
部分代码如下: @Override public Watermark getCurrentWatermark() { currentWaterMark = currentTimeStamp - ...
Linux:centos释放缓存,查看磁盘空间大小,xxx文件夹，查看文件夹大小,查看剩余内存,查看xxx软件位置,统计某文件夹,统计某文件夹下目录数量,查看文件夹大小，给文件夹下所有的文件赋值权限
一台老的PHP后台服务器,今天用 free -m 查看,发现内存跑满了. 再 top,然后按下shift+m,也就是按内存占用百分比排序,发现排在第一的进程,才占用0.9%,那是什么占用的呢?谷歌了一 ...
Certificate for ＜xxx.xxx.xxx.com＞ doesn‘t match any of the subject alternative names: [xxx..com]
问题和解决我这里先描述问题和解决方案吧.很多同学不太关心发生的背景. 问题表象 Certificate for <xxx.xxx.xxx.com> doesn't match any o ...
mybatisplus page排序_PostgreSQL使用WITH xxx AS()查询,使用Page中的OrderItem排序,会把WITH xxx AS()这段SQL忽略导致报错...
当前使用版本(必填,否则不予处理) 3.2.0 该问题是如何引起的?(确定最新版也有问题再提!!!) 目前更新到3.3.2版本问题一样存在 PostgreSQL使用WITH xxx AS()查询,使用 ...
交易码 MWS X7 会计科目表 XXX 没有在表 T030K 中定义/交易码 VST J2 会计科目表 XXX 没有在表 T030K 中定义
过帐时提示错误:"交易码 MWS X7 会计科目表 XXX 没有在表 T030K 中定义"或者"交易码 VST J2 会计科目表 XXX 没有在表 T030K 中定义&q ...
require xxx it is missing from your system. Install or enable PHP‘s xxx extension.
Your requirements could not be resolved to an installable set of packages. 在thinkphp6项目下,使用composer安 ...
electron 打包后启动应用报错：Error: ENOENT: no such file or directory, open ‘xxx/manifest.json‘‘
使用 electron-builder 打包后启动报错: Reading /xxx/manifest.json failed. Error: ENOENT: no such file or direc ...
【错误记录】Kotlin 编译报错 ( Class ‘Xxx‘ is not abstract and does not implement abstract member )
文章目录一.报错信息二.解决方案一.报错信息 Google Play 上架要求 Android 的编译版本和目标版本都要高于 30 才可以上传 ; 将 Android 的编译版本和目标版 ...
解决PyCharm中报出 “Shadows built-in name xxx“ 的警告
解决PyCharm中报出 "Shadows built-in name xxx" 的警告问题描述: PyCharm中报出 "Shadows built-in name ...

xxx in ‘Anonymous class derived from xxx clashes with ‘call(T)‘ in xxx attempting to use incompati

xxx in ‘Anonymous class derived from xxx clashes with ‘call(T)‘ in xxx attempting to use incompati相关推荐

最新文章

热门文章