UserInputFormat在mapreduce中的类

Question

请帮助我如何在mapreduce中创建UserInputFormat类以根据我的需要产生键值对。我需要将字符串的第一个字符存储为键，将整个字符串存储为valuw。如何实现

Answer 1

public static class UserInputFormat extends Mapper<Object, Text, Text, Text>{ //define datatype of key:value = Text:Text
public void map(Object key, Text value, Context context
                ) throws IOException, InterruptedException {
  String raw_String = value.toString(); 
  if (raw_String.length() > 0)
  {
        Text key_str = new Text(raw_String.substring(0, 1)); //get the first char of raw_String as key
          context.write(key_str, value); //key is the first character and value is the entire string
  }
}
}

我认为以上就是你所需要的。它是一个映射任务，将接收一个字符串作为输入，并将输出一对键:value -> [1stchar]:[整个字符串]。