Scala-没有足够的参数用于方法计数

Question

我对Scala和Spark RDD编程相当陌生。我使用的数据集是一个CSV文件，其中包含电影列表（每部电影一行）及其关联的用户评分（以逗号分隔的评分列表）。CSV中的每一列都代表一个不同的用户，以及他/她对电影的评价。因此，用户1对每部电影的评分在左侧第二列中表示：

示例输入：

蜘蛛侠，1,2,3,3

睡眠博士，4,4，，1

我得到以下错误：

Task4.scala:18: error: not enough arguments for method count: (p: ((Int, Int)) => Boolean)Int.
Unspecified value parameter p.
    var moviePairCounts = movieRatings.reduce((movieRating1, movieRating2) => (movieRating1, movieRating2, movieRating1._2.intersect(movieRating2._2).count()

当我执行下面的几行时。对于下面的程序，第二行代码拆分由“，”分隔的所有值，并生成以下结果：

（蜘蛛侠[1,0]，[2,1]，-1,2]，[3,3]，[3,4]）（睡眠博士[4,0]，[4,1]，-1,2]，-1,3]，[1,4]）

在第三行，获取count（）会抛出一个错误。对于每一部电影（一行），我都会尝试获取公共元素的数量。在上面的例子中，[-1，2]显然是蜘蛛侠和睡眠博士共同拥有的元素。

    val textFile = sc.textFile(args(0))
    
    var movieRatings = textFile.map(line => line.split(","))
                                .map(movingRatingList => (movingRatingList(0), movingRatingList.drop(1)
                                .map(ranking => if (ranking.isEmpty) -1 else ranking.toInt).zipWithIndex));
                                

    
    var moviePairCounts = movieRatings.reduce((movieRating1, movieRating2) => (movieRating1, movieRating2, movieRating1._2.intersect(movieRating2._2).count() )).saveAsTextFile(args(1));

我对3号线的目标输出如下：

（蜘蛛侠，睡眠博士，1）--

谁能给点建议吗？

Answer 1

错误消息似乎很清楚：count接受一个参数，但在您的调用中，您正在传递一个空参数列表，即零参数。您需要将一个参数传递给count。

Answer 2

要获取集合中的元素数，请使用length或sizecount（）返回满足某些附加条件的元素数。

或者，您可以使用count对第一个集合的元素进行计数，从而避免构建完整的交叉点，第二个集合包含：

movieRating1._2.count(movieRating2._2.contains(_))