0

私は Hadoop の初心者で、これが初めての Hadoop プログラムです。

WordMapper という Mapper クラスを作成しようとしていますが、以下のエラーがスローされます。

タイプ WordMapper は、継承された抽象メソッド Mapper.map(Object, Object, OutputCollector, Reporter) を実装する必要があります。

public class WordMapper extends MapReduceBase implements Mapper 
{
    public void map(WritableComparable key, Writable values, OutputCollector output, Reporter reporter) throws IOException 
    {
        String line=values.toString();
        StringTokenizer tok=new StringTokenizer(line);
        while(tok.hasMoreTokens())
        {
            String t=tok.nextToken();
            output.collect(new Text(t), new IntWritable(1));
        }

    }

}

誰かが私が間違っている場所を教えて、問題を克服することを提案できますか

4

2 に答える 2

2

次のように Mapper パラメータを満たすようにしてください。

public class WCMapper extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable>

public void map(LongWritable key, Text values, OutputCollector output, Reporter reporter)
于 2013-09-19T00:16:43.800 に答える