spark示例不会编译
尝试运行apachesparks示例代码之一(https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/graphx/AggregateMessagesExample.scala)我得到以下编译错误
too many arguments for method sendToDst: (msg: (Int, Double))Unit
[error] Error occurred in an application involving default arguments.
[error] triplet.sendToDst(1, triplet.srcAttr)
[error] ^
[error] one error found
但从方法上看，这似乎是正确的。不确定这里出了什么问题。
共有1个答案
看起来您正在调用的方法需要一个参数（Tuple2），并且您正在传递2个参数。
尝试
triplet.sendToDst((1, triplet.srcAttr))
-
问题内容： 我正在尝试运行JavaKinesisWordCountASL示例。 该示例似乎连接到我的Kinesis Stream并从该流中获取数据（如下面的日志所示）。但是，在示例中，Sparks不会调用传递给unionStreams.flatMap方法的调用函数，并且不会打印任何单词计数。 我尝试同时使用Java 8和Java 7运行。我正在ubuntu实例上运行它。相同的示例适用于我的Macb
-
主要内容：执行Spark字符计数示例的步骤在Spark字符统计示例中，将找出指定文件中每个字符的频率。在这里，使用Scala语言来执行Spark操作。 执行Spark字符计数示例的步骤 在此示例中，计算并显示每个字符的出现次数。在本地计算机中创建一个文本文件并在其中写入一些文本。 向sparkdata.txt 文件中写入的文本。 在HDFS中创建一个目录，保存文本文件。 将HDD上的sparkdata.txt 文件上传到特定目录中。 现在
-
主要内容：执行Spark字数计算示例的步骤在Spark字数统计示例中，将找出指定文件中存在的每个单词的出现频率。在这里，我们使用Scala语言来执行Spark操作。 执行Spark字数计算示例的步骤 在此示例中，查找并显示每个单词的出现次数。在本地计算机中创建一个文本文件并在其中写入一些文本。 检查文件中写入的文本。 在HDFS中创建一个目录，保存文本文件。 将HDD上的sparkdata.txt 文件上传到特定目录中。 现在，按照以下命
-
问题内容： 我刚刚在Google AppEngine / Java + GWT应用程序中启用了Session。以及如何使用它？我如何获得会话ID并从中播放所有好东西？是否有任何简单的登录页面的真实示例，我只是输入LoginName和Password，然后通过RPC调用转到服务器，针对数据库进行身份验证并将Session ID发送回客户端。 我已经有以下代码，但不知道下一步该怎么做： GWT登录表单
-
我试图运行示例目录中给出的python spark流作业- https://spark.apache.org/docs/2.1.1/streaming-programming-guide.html
-
问题内容： 谁能解释为什么下面的代码不能编译，而第二个代码可以编译？ 不编译 收集 线上的编译错误 IntStream类型的方法collect（Supplier，ObjIntConsumer，BiConsumer）不适用于参数（Collector>） 类型不匹配：无法从收集器>转换为供应商 编译 问题答案： 没有接受的方法。如果您想要，则必须将装箱到： 的替代方法是： 或者您可以使用以下 方法：