输入文件有两个:
-input "/home/hadoop/file1"
-input "/home/hadoop/file2"
在mapper文件中:
if 'file1' in os.getenv('map_input_file'):
//文件1处理逻辑
if 'file2' in os.getenv('map_input_file'):
//文件2处理逻辑
输入文件有两个:
-input "/home/hadoop/file1"
-input "/home/hadoop/file2"
在mapper文件中:
if 'file1' in os.getenv('map_input_file'):
//文件1处理逻辑
if 'file2' in os.getenv('map_input_file'):
//文件2处理逻辑
本文标题:python mr 区分多路输入
本文链接:https://www.haomeiwen.com/subject/ocfkhftx.html
网友评论