Как написать содержимое из файла mapper в файл - Hadoop

Question

Как написать содержимое mapper в файл. Это прекрасно.

public class MyMapper extends 
     Mapper<Object, Text, Text, MatrixWritable > { 
public void map(Object key, Text value, Context context) 
      throws IOException, InterruptedException { 

Configuration conf = new Configuration(); 
    FileSystem fs = FileSystem.get(conf); 

    Path inputfile = new Path("in/map"); 
    BufferedWriter getdatabuffer = new BufferedWriter(new OutputStreamWriter(fs.create(inputfile))); 
    if(value.toString()!= null){ 
      getdatabuffer.write(value.toString()); 
     } 
      getdatabuffer.close(); 

Если мой входной файл разбит, работает ли вышеуказанный код?

В редукторе я совмещаю все данные картографа.

РЕДАКТИРОВАТЬ

 Path inputfile = new Path("in/map"); 
      FSDataOutputStream out = fs.create(inputfile); 
     if(value.toString()!= null){ 
      out.writeBytes(value.toString()); 
     } 
      out.close(); 

Answer 1

Картопостроитель задача работать одновременно на нескольких узлах в кластере Hadoop. Ваш метод написания с обычными классами Java Writer не будет работать только потому, что вам нужно использовать API HDFS для записи данных.

Вместо этого в методе карты используйте context.write() для записи данных в файлы HDFS.