Redian新闻
>
忍不住说声 8年这个事件 (转载)
avatar
忍不住说声 8年这个事件 (转载)# Parenting - 为人父母
A*g
1
http://wiki.apache.org/hadoop/WordCount
这个程序的逻辑是看明白了,神奇的是在main里好像从来就没指定哪个是key,哪个是
value,就给了个输入输出文件名
这个map function
public void map(LongWritable key, Text value, Context context) throws
IOException, InterruptedException
还有reduce function是怎么知道那个是key 那个是value?
请大牛说说?
avatar
C*r
2
【 以下文字转载自 Dreamer 讨论区 】
发信人: Dreamer (不要问我从哪里来), 信区: Dreamer
标 题: 忍不住说声 8年这个事件
发信站: BBS 未名空间站 (Fri May 2 23:38:48 2014, 美东)
现在mitbbs上一边倒的样子,不过看那个男主人公,他老婆真的很可怜。他的回忆录里
面讽刺挖苦他老婆,虽然后面假惺惺地说理解他老婆,不过这是个睚眦必报的人,从他
威胁那个奶奶就能体现,这个老婆也太不容易了。
他们的结局非常不看好啊。
avatar
X*K
3
我不懂瞎猜的
public static class Map extends Mapper>
就是说这个mapper把input pair
LongWritable, Text (行id,行文本)
map到output pair
Text, IntWritable(词,数字1)
而map function
public void map(LongWritable key, Text value, Context context) throws
IOException, InterruptedException
的前两个参数就是input pari,Context应该就是hadoop句柄,然后
context.write(word, one);
就是输出output pair.
reducer应该也类似
avatar
A*g
4
有道理,所以map的input就是以input file的行读的

IntWritable

【在 X*K 的大作中提到】
: 我不懂瞎猜的
: public static class Map extends Mapper: >
: 就是说这个mapper把input pair
: LongWritable, Text (行id,行文本)
: map到output pair
: Text, IntWritable(词,数字1)
: 而map function
: public void map(LongWritable key, Text value, Context context) throws
: IOException, InterruptedException

avatar
A*g
5
http://wiki.apache.org/hadoop/WordCount
这个程序的逻辑是看明白了,神奇的是在main里好像从来就没指定哪个是key,哪个是
value,就给了个输入输出文件名
这个map function
public void map(LongWritable key, Text value, Context context) throws
IOException, InterruptedException
还有reduce function是怎么知道那个是key 那个是value?
请大牛说说?
avatar
X*K
6
我不懂瞎猜的
public static class Map extends Mapper>
就是说这个mapper把input pair
LongWritable, Text (行id,行文本)
map到output pair
Text, IntWritable(词,数字1)
而map function
public void map(LongWritable key, Text value, Context context) throws
IOException, InterruptedException
的前两个参数就是input pari,Context应该就是hadoop句柄,然后
context.write(word, one);
就是输出output pair.
reducer应该也类似
avatar
A*g
7
有道理,所以map的input就是以input file的行读的

IntWritable

【在 X*K 的大作中提到】
: 我不懂瞎猜的
: public static class Map extends Mapper: >
: 就是说这个mapper把input pair
: LongWritable, Text (行id,行文本)
: map到output pair
: Text, IntWritable(词,数字1)
: 而map function
: public void map(LongWritable key, Text value, Context context) throws
: IOException, InterruptedException

相关阅读
logo
联系我们隐私协议©2024 redian.news
Redian新闻
Redian.news刊载任何文章,不代表同意其说法或描述,仅为提供更多信息,也不构成任何建议。文章信息的合法性及真实性由其作者负责,与Redian.news及其运营公司无关。欢迎投稿,如发现稿件侵权,或作者不愿在本网发表文章,请版权拥有者通知本网处理。