输入文件有两个:
-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处理逻辑