没有合适的资源?快使用搜索试试~ 我知道了~
代码啊代码,活生生的代码啊,不是我写的是hadoop自带的代码啊
资源推荐
资源详情
资源评论






格式:docx 资源大小:401.1KB 页数:6



格式:doc 资源大小:50.5KB 页数:5













格式:rar 资源大小:18.1KB







package org.apache.hadoop.examples;
import java.io.IOException;
import java.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.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.output.FileOutputFormat;
import org.apache.hadoop.util.GenericOptionsParser;
public class WordCount {
public static class TokenizerMapper
extends Mapper<Object, Text, Text, IntWritable>{
private final static IntWritable one = new IntWritable(1);
private Text word = new Text();
public void map(Object key, Text value, Context context
) throws IOException, InterruptedException {
StringTokenizer itr = new StringTokenizer(value.toString());
while (itr.hasMoreTokens()) {
word.set(itr.nextToken());
context.write(word, one);
import java.io.IOException;
import java.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.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.output.FileOutputFormat;
import org.apache.hadoop.util.GenericOptionsParser;
public class WordCount {
public static class TokenizerMapper
extends Mapper<Object, Text, Text, IntWritable>{
private final static IntWritable one = new IntWritable(1);
private Text word = new Text();
public void map(Object key, Text value, Context context
) throws IOException, InterruptedException {
StringTokenizer itr = new StringTokenizer(value.toString());
while (itr.hasMoreTokens()) {
word.set(itr.nextToken());
context.write(word, one);
资源评论


u014372952
- 粉丝: 0
上传资源 快速赚钱
我的内容管理 展开
我的资源 快来上传第一个资源
我的收益
登录查看自己的收益我的积分 登录查看自己的积分
我的C币 登录后查看C币余额
我的收藏
我的下载
下载帮助


最新资源
- TalkingData+大数据技术与应用实践.pdf
- 计算机+新时代背景下的大学生计算机基础实践教学的思考与探索.docx
- JAVA语言程序设计期末考试试题及答案14439.doc
- 无线网络覆盖设计方案.doc
- 信息网络安全事故应急预案.doc
- 独立学院计算机基础课程教学改革研究与实践.docx
- 个毕业设计-单片机类数字抢答器(数字电路).doc
- WEB站点性能优化实践(加载速度提升2s).docx
- 解读建设工程管理的信息化发展.docx
- 新形势下计算机网络的运行及维护策略研究.docx
- 计算机科学导论课后练习翻译要点.doc
- 单片机和LM的温测量系统[].doc
- matlab图像预处理技术研究文献综述.doc
- 数据库原理与技术课程设计方案任务书.doc
- 餐饮ERP软件功能模块介绍.ppt
- 电磁波与信息化社会.ppt
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈



安全验证
文档复制为VIP权益,开通VIP直接复制
