predictionio优化-成都创新互联网站建设

关于创新互联

多方位宣传企业产品与服务 突出企业形象

公司简介 公司的服务 荣誉资质 新闻动态 联系我们

predictionio优化

predictionio 的validScores方法 有点问题,因为model对象中的一个属性类型为Map items,在数据量很大的时候,肯定是不行,所以优化一下,采用join+filter的模式,代码如下

创新互联专注于桃源网站建设服务及定制,我们拥有丰富的企业做网站经验。 热诚为您提供桃源营销型网站建设,桃源网站制作、桃源网页设计、桃源网站官网定制、小程序定制开发服务,打造桃源网络公司原创品牌,更为您提供桃源网站排名全网营销落地服务。

return all.mapToPair(new PairFunction() {
            @Override
            public Tuple2 call(ItemScore idUser) throws Exception {
                return new Tuple2<>(idUser.getItemEntityId(), idUser);
            }
        }).join(model.getItems()).filter(new Function>, Boolean>() {
            @Override
            public Boolean call(Tuple2> itemScore) throws Exception {
                /*Item item = items.get(itemScore.getItemEntityId());*/

                Item item =itemScore._2._2;
                //logger.info("join end");

                return (item!=null && /*item != null 
                        && */passWhitelistCriteria(whitelist, itemScore._2._1.getItemEntityId())
                        && passBlacklistCriteria(blacklist, itemScore._2._1.getItemEntityId())
                       /* && passCategoryCriteria(categories, item)*/
                       /* && passUnseenCriteria(seenItemEntityIds, itemScore.getItemEntityId())*///看过或买过的不要
                       /* && passAvailabilityCriteria(unavailableItemEntityIds, itemScore.getItemEntityId())*/);
            }
        }).map(new Function>, ItemScore>() {
             @Override
             public ItemScore call(Tuple2> userItemCount) throws Exception {
                 return userItemCount._2._1;
             }
         });

本文名称:predictionio优化
分享链接:http://kswsj.cn/article/gijjoc.html

其他资讯