のjava.lang.Exception：java.lang.ClassCastExceptionが：私はなってこのコードを実行しようとしているときorg.apache.hadoop.io.Textはorg.apache.hadoop.io.IntWritable

Question

public class PrimeMapper extends Mapper<LongWritable,IntWritable,IntWritable,NullWritable> 
    { 
     public void map(LongWritable k,IntWritable val,Context c) throws IOException, InterruptedException 
      { 
       int v=val.get(); 
       int i=2; 
       if(v==1) 
       c.write(new IntWritable(v), NullWritable.get()); 
       for(i=2;i<v;i++) 
        { 
         if(v%i==0) 
         break; 
        } 
       if(v==i) 
       c.write(new IntWritable(v),NullWritable.get()); 
      } 
    } 

にキャストすることはできません型キャストエラーのエラー。

Answer 1

もしTextInputFormat（FileInputFormat<LongWritable, Text>を拡張）は、デフォルトの入力フォーマットを使用すると、マッパーはkeyとvalueとしてTextとしてLongWritableを期待。プログラムでこれを明示的に変更していない場合は、マッパー定義が正しくありません。

正しい実装は次のようになります。

public class PrimeMapper extends Mapper<LongWritable,Text,IntWritable,NullWritable>{ 
    public void map(LongWritable k,Text val,Context c) throws IOException, InterruptedException{ 
    int v=Integer.parseInt(val.toString().trim()); 
    int i=2; 
    if(v==1) 
    c.write(new IntWritable(v), NullWritable.get()); 
    for(i=2;i<v;i++) 
     { 
      if(v%i==0) 
      break; 
     } 
    if(v==i) 
    c.write(new IntWritable(v),NullWritable.get()); 
    } 
}