пустой выходной файл при преобразовании из String в IntWritable - PullRequest
Новая
       145

пустой выходной файл при преобразовании из String в IntWritable

1 голос
/ 12 июля 2020

я устанавливаю входной файл как файл CSV, как только я пытаюсь преобразовать из String в IntWritable, я получаю пустой выходной каталог 

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

import java.io.IOException;
import java.util.StringTokenizer;

public class MapperClass
        extends Mapper<Object, Text, Text, IntWritable>{

    private IntWritable unitSold= new IntWritable();
    private Text itemType = new Text();
    private String[] data;

    public void map(Object key, Text value, Mapper.Context context
    ) throws IOException, InterruptedException , NumberFormatException {
        StringTokenizer itr = new StringTokenizer(value.toString(),"\n");
        
        while (itr.hasMoreTokens()) {
            data=itr.nextToken().split(",");
            itemType.set(data[2]);

            unitSold.set(Integer.parseInt(data[8].toString())); // the line that cause the problem after its added 
            if (data[3].contains("Offline"))
                context.write(itemType,unitSold);
        }
    }
}
...