1回答
我现在使用的是用实现的ALS。在目录/org/apache/spark/中有两个不同的包。这两个包中的每个包都有子文件夹recommendation，并且在这个文件夹中有类ALS.scala (mllib还有其他的MatrixFactorizationModel.scala)
我的问题是，ml例如，我在网上找到了Apache Spar
浏览 7提问于2016-09-12得票数 2
回答已采纳
2回答
我正在努力在星火上实施ALS。我使用ml类而不是mllib，因为CSV文件在一列中包含字符串。mllib中的评级类不接受字符串作为参数。我想使用来自org.apache.spark.mllib.recommendation.MatrixFactorizationModel类的预测函数，但是在运行时它正在org.apache.spark.rdd.RDD中搜索。这是我正在使用的代码。
import or
浏览 2提问于2016-03-08得票数 1
我一直在使用trainImplicit时看到这些警告
WARN TaskSetManager: Stage 246 contains a task of very large size (208 KB)我试图在输入RDD上调用repartition，但是警告是相同的。所有这些警告来自ALS迭代，来自flatMap，也来自聚合，例如，flatMap显示这些警告的阶段的起源(w/ Spark1.3.0，但它们也显示在Spark1
浏览 2提问于2015-04-22得票数 14
1回答
我正在试用在Spark中实现的协作过滤算法，并遇到以下问题：u1|p1|3u2|p1|2现在，如果我用以下数据测试它：u3|p1|2我从来没有看到用户'u3‘的任何评级，大概是因为该用户没有出现在培训数据中。我的印象是，这个问题只适用于新产品。在这种情况下，我会期望'u3‘的预测，因为'u1’和'u2‘<
浏览 1提问于2015-03-20得票数 5
回答已采纳
我试着用sbt制造一个复杂的问题。教程：[error] /home/zeng/workspace/spark/als/src
浏览 1提问于2016-08-24得票数 0
回答已采纳
2回答
我们使用ALS在Azure火场建立我们的推荐系统。
15/11/16 15:43:11 INFO TaskSetManager: State15.0 (TID 197)中在exec
浏览 3提问于2015-11-19得票数 2
我正在尝试使用Spark构建一个推荐系统，其中的数据如下276725;034545104;0还有什么其他的解决办法可以让事情顺利进行吗？对于同样的问题，我得到了这些建议(，和)，
浏览 3提问于2017-01-16得票数 2
1回答
我对Spark的肌萎缩侧索硬化症推荐有问题。我想使用以下代码来预测我系统中的每个用户的产品als_model = ... # trained ALS modelrecommendations = users.map(lambda u: als_model.recommendProducts(u, 5))
不幸<e
浏览 0提问于2016-02-16得票数 1
我正在使用Spark MLlib的ALS类来训练一个MatrixFactorizationModel。我已经为中间rdd设置了一个用于检查点的HDFS (根据ALS类的建议)。$$anonfun$2$$anonfun$apply$mcV$sp$1.apply(ALS.scala:568)
at org.apache.spark.ml.recommendation.ALS$$anonfun$$anonfun$2.apply$mcV$sp
浏览 4提问于2015-08-13得票数 0
我正在用ALS训练一个推荐系统(星火版本: 1.3.1)。现在，我想通过交叉验证使用Pipeline进行模型选择。] = // ...val pipeline = new Pipeline(ALS.scala:148)
at org.apache.spark.ml.recommendation.ALS.validateAndTransfo
浏览 2提问于2015-05-09得票数 0
回答已采纳
1回答
在ApacheSpark1.0.0中运行Scala程序时，会遇到以下错误。$$anonfun$org$apache$spark$mllib$recommendation$ALS$$updateBlock$2.apply(ALS.scala:522)
at org.apache.spark.mllib.recommendation.ALS$apache$spark$mllib$recommendation$ALS$$up
浏览 1提问于2014-07-15得票数 8
回答已采纳
我正在尝试从Java中的Apache示例mlib推荐器构建一个示例推荐程序，但是当我构建它时(在IDEA intellij中)，输出日志显示at org.apache.spark.Logging$class.log(Logging.scala:52)
at org.apache.spark.mllib.recommendation.ALS
浏览 2提问于2015-04-01得票数 0
回答已采纳
当我尝试执行主类时，在代码的某一行，它为类Exception in thread "main" java.lang.NoClassDefFoundError提供了错误org.apache.spark.ml.recommendation.ALS-*.jar --rank 10 --path 看起来它只是找不到org.apache.spark.ml.recommendation.ALS。{SparkCon
浏览 5提问于2016-05-23得票数 0
1回答
我有一个简单的Python应用程序。我的问题是，预测方法需要超过一秒的时间来预测用户和产品之间的评分。我的服务器是32G和8核。任何建议，我可以提高预测时间小于100毫秒。以及数据集中的记录数量与预测时间之间的关系。下面是我正在做的事情：
spark_config = SparkConf().setAll([('spark.executor.memory', '32g'), (
浏览 1提问于2017-08-22得票数 0
根据这篇文章： Spark2.0包括一个独立于语言的模型序列化。
这是否支持使用spark训练模型，并使用非jvm语言(如python中使用的没有jvm后端的python)提供模型？
浏览 2提问于2016-06-02得票数 0
1回答
我只想问一下如何在星火中成功地使用checkpointInterval的具体细节。在ALS：的代码中，这个注释是什么意思？如果[org.apache.spark.SparkContext]中没有设置检查点目录，则忽略此设置。
如何设置checkPoint目录？我们可以使用任何与hdfs兼容的目录吗？使用setCheckpointInterval是否是在ALS中实现检查点以避免堆
浏览 1提问于2016-01-06得票数 5
回答已采纳
1回答
建议的备用最小二乘算法的Spark实现，生成一个模型，该模型可应用于已观看电影的项目(training.itemCol，(在下面的示例中)，以便建议新项(示例中为movieRecs)。该方法如何返回已监视的(非新的)项作为结果的一部分(userRecs)？als = ALS(maxIter=5, regParam=0.01, userCol="userId",
浏览 1提问于2020-03-09得票数 0
回答已采纳
我正试图在我的上运行ALS模型，而且我总是遇到同样的错误：spark_config["spark.executor.memory"] = "32G"这是我的模特训练。10, seed=0)以下是我的</e
浏览 15提问于2022-08-25得票数 0
2回答
我正在尝试测试pyspark是否在我的系统上正常运行，但是当我尝试对我的数据调用fit时，我得到了错误，"Requirement : Nothing is but to this summarizer“import findsparkspark_location='/usr/local/spark/'
java8_location= '/usr/lib/jvm/ja
浏览 1提问于2019-11-13得票数 2
1回答
我有一个只有两个字段的数据集，itemId，productid，我想尝试使用mahout ALS或mllib进行隐式反馈，在数据集中创建全为1的首选项列是最好的方法吗？阅读韩国论文(针对隐式反馈数据集的协作过滤)我发现，对于相同的偏好，所有的置信区间都是相同的，这是好的吗？谢谢!
浏览 4提问于2015-06-01得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
