如何将java类对象作为mapreduce中map函数的输入?

Question

如何将java类对象作为mapreduce中map函数的输入?

Answer 1

1首先介绍一下wordcount 早mapreduce框架中的 对应关系 大家都知道 mapreduce 分为 map 和reduce 两个部分，那么在wordcount例子中，很显然 对文件word 计数部分为map，对 word 数量累计部分为 reduce； 大家都明白 map接受一个参数，经过map处如何将java类对象作为mapreduce中map函数的输入?