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

本文整理汇总了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

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

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

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