云計(jì)算實(shí)驗(yàn)報(bào)告-資料下載頁(yè)
2025-07-25 07:06本頁(yè)面
【正文】 ce后，jps結(jié)果如下：masterslave停止集群運(yùn)行程序（1） 在Eclipse下，新建map/reduce工程（2） 新建一個(gè)java類UserNameCount，編寫代碼（3） 運(yùn)行程序，結(jié)果如下：（4） 在eclipse中編譯好源代碼后，導(dǎo)出程序的jar包，供在集群上使用。（1） 啟動(dòng)集群，通過(guò)jps命令查看master，slave上啟動(dòng)的服務(wù)列表，結(jié)果如下：（2） 在集群環(huán)境下運(yùn)行該程序jar包（），結(jié)果如下：（3） 查看集群環(huán)境下啟動(dòng)程序生成的結(jié)果，即output文件，結(jié)果如下：（4） 數(shù)據(jù)統(tǒng)計(jì)結(jié)果在partr00000中，具體內(nèi)容如下，源代碼：package hadoop。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。public class UserNameCount { public static class UserNameCountMap extends MapperLongWritable, Text, Text, IntWritable { private final IntWritable one = new IntWritable(1)。 private Text word = new Text()。 public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException { String line = ()。 StringTokenizer token = new StringTokenizer(line)。 while (()) { (())。 (word, one)。 } } } public static class UserNameCountReduce extends ReducerText, IntWritable, Text, IntWritable { public void reduce(Text key, IterableIntWritable values, Context context) throws IOException, InterruptedException { int sum = 0。 for (IntWritable val : values) { sum += ()。 } (key, new IntWritable(sum))。 } } public static void main(String[] args) throws Exception { Configuration conf = new Configuration()。 Job job = new Job(conf)。 ()。 (usernamecount)。 ()。 ()。 ()。 ()。 ()。 ()。 (job, new Path(args[0]))。 (job, new Path(args[1]))。 (true)。 }}
醫(yī)療健康相關(guān)推薦
鄂ICP備17016276號(hào)-1