在Spark Java应用程序中使用Tuple2时的编译错误

Question

我正在Eclipse Luna中使用Java1.8尝试Spark编程示例，并有以下代码-

JavaPairRDD<String, Integer> counts = ones
                .reduceByKey(new Function2<Integer, Integer, Integer>() {
                    @Override
                    public Integer call(Integer i1, Integer i2) {
                        return i1 + i2;
                    }
                });
List<Tuple2<String, Integer>> output = counts.collect(); //Compilation Error

我使用M2Eclipse构建和创建jar，并使用spark-submit在本地执行jar。jar正在工作并打印正确的输出，但是Eclipse总是将上面提到的行显示为编译错误-类型Tuple2不是泛型的；不能用参数 参数化

我不明白为什么Eclipse将其显示为编译错误，因为collect调用的返回类型是列表 >

非常感谢任何帮助。

Answer 1

它也有助于解决我在IntelliJ想法上的问题。我调用了一个函数，其中的参数是泛型类型，参数为Tuple2。它总是显示一个错误，但我可以通过编译。这让我困惑了好几天。在删除几个依赖的Sharded-Jar（其中包含一些相关的scala-libiary）之后，错误消失了。