如何通过map reduce实现文件传输？为了实现这一点，我需要在mapper、reducer和job的输入输出中设置哪些参数？
bhmjp9jg1#
假设是纯文本文件，您只需让mapper和reducer精确地输出它们得到的内容。然后，输出包含与输入相同的所有行。
void map(LongWriteable key, Text value, Context context) { context.write(key, value); }
void reduce(LongWritable key, Iterable<Text> values, Context context) { for (Text t : values) context.write(key, value); }
1条答案
按热度按时间bhmjp9jg1#
假设是纯文本文件，您只需让mapper和reducer精确地输出它们得到的内容。然后，输出包含与输入相同的所有行。