扩展一个类，该类扩展Hadoop的Mapper

import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import import org.apache.hadoop.mapreduce.Mapper;

public class CustomMapper extends Mapper<LongWritable, Text, Text, Text> {
    
    @Override
    protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
        // 自定义的Mapper逻辑
        // 对输入数据进行处理和转换
        // 将处理结果写入Context中作为输出
        
        // 示例：将输入的每一行数据按照制表符进行分割，并将第一个字段作为输出的键，第二个字段作为输出的值
        String[] fields = value.toString().split("\t");
        if (fields.length >= 2) {
            String outputKey = fields[0];
            String outputValue = fields[1];
            context.write(new Text(outputKey), new Text(outputValue));
        }
    }
}