hadoop案例实现之计算单词出现的频数

Joanna.Y 2024-05-22 00:07:40
最佳回答
1编写j**a代码,实现map函数以及reduce函数package com.paic.el**.test;import j**a.io.ioexception;import j**a.util.stringtokenizer;import org.apache.hadoop.conf.configuration;import org.apache.hadoop.fs.path;import org.apache.hadoop.io.intwritable;import org.apache.hadoop.io.longwritable;import org.apache.hadoop.io.text;import org.apache.hadoop.mapreduce.job;import org.apache.hadoop.mapreduce.mapper;import org.apache.hadoop.mapreduce.reducer;import org.apache.hadoop.mapreduce.lib.input.fileinputformat;import org.apache.hadoop.mapreduce.lib.input.textinputformat;import org.apache.hadoop.mapreduce.lib.output.fileoutputformat;import org.apache.hadoop.mapreduce.lib.output.textoutputformat;public class wordcount {public static class wordcountmap extendsmapper<longwritable, 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 = value.tostring();stringtokenizer token = new stringtokenizer(line);while (token.hasmoretokens()) {word.set(token.nexttoken());context.write(word, one);}}}public static class wordcountreduce extendsreducer<text, intwritable, text, intwritable> {public void reduce(text key, iterable<intwritable> values,context context) throws ioexception, interruptedexception {int sum = 0;for (intwritable val : values) {sum += val.get();}context.write(key, new intwritable(sum));}}public static void main(string[] args) throws exception {configuration conf = new configuration();job job = new job(conf);job.setjarbyclass(wordcount.class);job.setjobname("wordcount");job.setoutputkeyclass(text.class);job.setoutputvalueclass(intwritable.class);job.setmapperclass(wordcountmap.class);job.setreducerclass(wordcountreduce.class);job.setinputformatclass(textinputformat.class);job.setoutputformatclass(textoutputformat.class);fileinputformat.addinputpath(job, new path(args[0]));fileoutputformat.setoutputpath(job, new path(args[1]));job.waitforcompletion(true);}}2打包成ja**件并上传到远程云主机。0如何将j**a源码打包成可执行的ja**件win&linux3将文件通过ssh传到远程来4在hadoop中创建文件夹,并将linux 主机的内容上传到hdfs中。5查看是否上传成功。6执行。7执行过程输出8查看结果:8该信息非法爬取自百度经验9输入的文本信息:end 20210311
汇率兑换计算器

类似问答
  • 计算持有至到期投资的实际利率,在不告诉现值系数的情况下计算。
    • 2024-05-22 04:28:24
    • 提问者: 未知
    f(r)=5000*6%(1+r)^-1+5000*6%(1+r)^-2+5000*6%(1+r)^-3 =5000*6%((1+r)^-1+(1+r)^-2+(1+r)^-3)在这个时候用等比数列公式然后可得到 f(r)=5000*6%+((1-(1+r)^-3)/r 然后接下来就用插值法,再用插值法之前先用简化公式求,简化公式的原理根据无穷极限的思想推导可得简化公式就是f’(r)=5...
  • 有哪些计数的英语单词,比如million
    • 2024-05-22 02:36:04
    • 提问者: 未知
    1)根据美国英语中每逢四位数...第二个“,”号前为million,第三个“,”号前为billion(在英国英语**中为thousand million),然后一节一节表示。例如:123,456,895.
  • 数据挖掘中最经典的案例之一-啤酒与尿布是真实的案例吗?
    • 2024-05-22 23:42:26
    • 提问者: 未知
    beer and nappies-a data mining ** legend 这里有一个链接是分析这个案例是否真实的。大致看了一下,作者的观点如下: 作者向一个人提及这个故事,那个人要么笨的像牛...
  • 都有哪些营销案例是利用ar技术实现的?
    • 2024-05-22 00:09:52
    • 提问者: 未知
    除了经典的哈根达斯拉提琴的案例外。
  • hadoop实现mapreduce与**ro结合使用的案例
    • 2024-05-22 23:47:34
    • 提问者: 未知
    建议自学,有问题可以有针对性的提问
  • 实现会计核算真实性的措施有哪些
    • 2024-05-22 14:25:50
    • 提问者: 未知
    会计核算职能是指会计对客观经济活动的表述和价值数量上的确定,为管理经济活动提供所需的会计信息。会计核算是会计工作的重要组成部分,以货币为主要计量单位,对企业、单位一定时期的经济活动...
  • 交行取现的数目会出现在账单上吗?
    • 2024-05-22 14:51:40
    • 提问者: 未知
    会显示的啊,1000元利息是每天5毛钱,你自己算一下,你取了几天去还一下就可以了,手续费10元
  • 回报率的计算公式,最好能给个简单的案例
    • 2024-05-22 07:51:52
    • 提问者: 未知
    投资回报率?你开办企业就意味着把自己的时间、精力和金钱进行长期、日常的投资。你这么做是因为你相信有一天公司的回报将大于目前所投入的时间、精力和金钱的价值。不经意...
  • 高频交易为什么会出现大量撤单?
    • 2024-05-22 09:45:03
    • 提问者: 未知
    新闻上说,**负责人称,在股市异常波动期间,一些具有程序化交易特征的账户参与其中,频繁报撤单,少数账户委托撤单比超过80%,干扰正常价格信号。 高频交易为什么要狂撤单?
  • 视频会议解决方案是如何实现的
    • 2024-05-22 15:27:00
    • 提问者: 未知
    楼主您好,目前无非就是硬件或者软件呗,硬件的要根据客户情况针对性的做方案,因为每个案例的实际网络环境和应用需求是大不一样的。软件的比较简单可以直接给您些建议。每个软件产品都不尽相同,市场也是让很多客户眼花缭乱,别尽听一些商家的花里胡哨,一定找些大的专业公司,比如一些的产品起码的一些各种保障您是可以放心的。业界来说较完善的软件视频会议产品是手机、座机、电脑都可以直接参会,要是还可以在手机上安装客户端...
汇率兑换计算器

热门推荐
热门问答
最新问答
推荐问答
新手帮助
常见问题
房贷计算器-九子财经 | 备案号: 桂ICP备19010581号-1 商务联系 企鹅:2790-680461

特别声明:本网为公益网站,人人都可发布,所有内容为会员自行上传发布",本站不承担任何法律责任,如内容有该作者著作权或违规内容,请联系我们清空删除。