java.lang.Exception: java.lang.ClassCastException: org.apache.hadoop.io.Text ne peut pas être jeté à 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()); 
      } 
    } 

quand je suis en train d'exécuter ce code i obtenir erreur d'erreur de typage.

Answer 1

Lorsque vous utilisez le format d'entrée par défaut qui est TextInputFormat (étend FileInputFormat<LongWritable, Text>), le cartographe attend LongWritable que key et Text comme value. Si vous n'avez pas modifié cela explicitement dans votre programme, votre définition de mappeur est incorrecte.

Une mise en œuvre correcte ressemblerait à quelque chose comme ceci:

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()); 
    } 
}