Java FlatMapFunction in Spark: error: is not abstract and does not override abstract method解决方案

本文受到[1]的启发,但是和[1]中的解决方案不完全相同。

原始代码如下:

JavaRDD<String> lines = input.flatMap(new FlatMapFunction<String, String>(){public Iterable<String> call(String s) throws Exception{return Arrays.asList(s.split(" "));}});

intellij提示:

'call(String)' in 'Anonymous class derived from org.apache.spark.api.java.function.FlatMapFunction' clashes with 'call(T)' in 'org.apache.spark.api.java.function.FlatMapFunction'; attempting to use incompatible return type

intellij如果强行运行wordcount:

改成:

JavaRDD<String> lines = input.flatMap(new FlatMapFunction<String, String>(){public Iterator<String> call(String s) throws Exception{return Arrays.asList(s.split(" ")).iterator();}});

Reference:

[1]关于《Spark快速大数据分析》运行例子遇到的报错及解决

Java FlatMapFunction in Spark: error: is not abstract and does not override abstract method解决方案相关推荐

Java代码使用Spark on Yarn 方式提交任务到带Kerberos认证的Hadoop集群
2019独角兽企业重金招聘Python工程师标准>>> 项目中遇到Spark Yarn方式提交到Hadoop集群,访问集群HDFS时发现使用的当前用户,没有访问权限,经过排查后发现H ...
Spark Launcher Java API提交Spark算法
在介绍之前,我先附上spark 官方文档地址: http://spark.apache.org/docs/latest/api/java/org/apache/spark/launcher/packa ...
Java的异常：Error与Exception
Java的异常:Error与Exception 参考文章: (1)Java的异常:Error与Exception (2)https://www.cnblogs.com/heqiyoujing/p/11 ...
java.util.zip.ZipException: error in opening zip file
今天在eclipse上新建了一个java项目,将其打包为jar文件,上传到linux上进行运行时出错了:错误内容为: java.util.zip.ZipException: error in open ...
编译环境与生成环境的JDK版本不一样，报：java.util.zip.ZipException: error in opening zip file
分享一下我老师大神的人工智能教程!零基础,通俗易懂!http://blog.csdn.net/jiangjunshow 也欢迎大家转载本篇文章.分享知识,造福人民,实现我们中华民族伟大复兴! 发布应用 ...
java异常中的Error和Exception的区别是什么？
java异常中的Error和Exception的区别是什么? 参考文章: (1)java异常中的Error和Exception的区别是什么? (2)https://www.cnblogs.com/Tr ...
java.io.IOException: CreateProcess error=2, ?????????
最近由于工作需要,使用java在调用cmd程序时,为了避免在路径当中有多个空格(例如:c:\\aa a\t t\m m),所以使用了 Runtime time = Runtime.getR ...
Error querying database. Cause: java.lang.NullPointerException .The error occurred while handlin
问题描述: 今天在复习mybatis的时候,自己查询练习遇到一个错误,十分无语错误信息如下 org.apache.ibatis.exceptions.PersistenceException: ## ...
Exception in thread' main” java. 1ang. Runt imeException: Error while running command to get file pe
Exception in thread' main" java. 1ang. Runt imeException: Error while running command to get fi ...

Java FlatMapFunction in Spark: error: is not abstract and does not override abstract method解决方案

Java FlatMapFunction in Spark: error: is not abstract and does not override abstract method解决方案相关推荐

最新文章

热门文章