• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

Java RecommenderJob类的典型用法和代码示例

java 1次浏览

本文整理汇总了Java中org.apache.mahout.cf.taste.hadoop.item.RecommenderJob的典型用法代码示例。如果您正苦于以下问题:Java RecommenderJob类的具体用法?Java RecommenderJob怎么用?Java RecommenderJob使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

RecommenderJob类属于org.apache.mahout.cf.taste.hadoop.item包,在下文中一共展示了RecommenderJob类的3个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: run

点赞 3

import org.apache.mahout.cf.taste.hadoop.item.RecommenderJob; //导入依赖的package包/类
public void run() throws Exception{
	long startTime = System.currentTimeMillis();
	JobConf conf = new JobConf(ItemCFJob.class);
	conf.setJobName("ItemCF"+System.currentTimeMillis());
	conf.setNumMapTasks(10);
	conf.set("io.serializations", "org.apache.hadoop.io.serializer.JavaSerialization,"
					+ "org.apache.hadoop.io.serializer.WritableSerialization");
	StringBuilder sb = new StringBuilder();
	sb.append("--input ").append(input);
	sb.append(" --output ").append(output);
	if (flag){
		sb.append(" --booleanData true");
	}else{
		sb.append(" --booleanData false");
	}
	sb.append(" --similarityClassname " + Constants.mahout_similarityclassname);
	sb.append(" --tempDir ").append(tmp);
	String[] args = sb.toString().split(" ");
	RecommenderJob job = new RecommenderJob();
	job.setConf(conf);
	job.run(args);
	long endTime = System.currentTimeMillis();
	logger.info("recommdation job ["+conf.getJobName()+"] run finish. it costs"+ (endTime - startTime) / 1000 +"s.");
}
 

开发者ID:bytegriffin,
项目名称:recsys-offline,
代码行数:25,
代码来源:ItemCFJob.java

示例2: main

点赞 3

import org.apache.mahout.cf.taste.hadoop.item.RecommenderJob; //导入依赖的package包/类
public static void main(String args[]) throws Exception {
	String newArgs [] = new String[6];
	newArgs[0] = "-Dmapred.input.dir="+args[0];
	newArgs[1] = "-Dmapred.output.dir=" + args[1];
	newArgs[2] = "--similarityClassname";
	newArgs[3] = SIMILARITY_CLASS_NAME;
	newArgs[4] = "--numRecommendations";
	newArgs[5] = NUM_RECOMMENDATIONS;
	long [] bw = new long[2];
	bw[0] = 100l;
	bw[1] = 101l;
	List<Long> longs = Longs.asList(bw[0], bw[1]);
	System.out.println(longs.get(0));
	System.out.println(longs.get(1));
	RecommenderJob.main(newArgs);
}
 

开发者ID:h20,
项目名称:MusicBigData,
代码行数:17,
代码来源:ItemBasedRecommendations.java

示例3: main

点赞 2

import org.apache.mahout.cf.taste.hadoop.item.RecommenderJob; //导入依赖的package包/类
public static void main(String[] args) throws Exception
{
	ToolRunner.run(new Configuration(), new RecommenderJob(), args);
}
 

开发者ID:beeldengeluid,
项目名称:zieook,
代码行数:5,
代码来源:RecommenderJobZieOok.java


版权声明:本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。
喜欢 (0)