我可以在映射器函数中使用内置的InputFormat来读取以下格式的输入行:

Name [key1#val1,key2#val2,key3#val3,key4#val4]

示例输入数据可能如下所示:
sanjose [population#123,area#123,address#1,jkui,ty,tz#PST]
delhi [population#1823,area#1023,address#1,jkui,ty,tz#IST]
boston [population#1823,area#1023,address#1,jkui,ty,tz#EST]

最佳答案

设置属性mapreduce.input.keyvaluelinerecordreader.key.value.separator并使用job.setInputFormatClass(KeyValueTextInputFormat.class);
在您的情况下,我相信\t是键值分隔符

关于hadoop - Hadoop Mapper读取键值对,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/25687934/

10-16 02:38