Eclipse не сохраняет файлы в Hadoop - PullRequest
0 голосов
/ 17 декабря 2018

eclipse не создает файл borrarSecuence.txt в файловой системе hadoop, но когда я запускаю его с hadoop jar /home/javier/input/Untitled.jar com.main.SecuenceFile в оболочке, создаю мне файл borrarSecuence.txt

package com.main;
import java.io.IOException;
import java.io.Serializable;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.SequenceFile;
import org.apache.hadoop.io.SequenceFile.Reader;
import org.apache.hadoop.io.SequenceFile.Writer;
import org.apache.hadoop.io.Text;
@SuppressWarnings("serial")
public class SecuenceFile extends Configuracion implements Serializable{
    Path filePath;
    public SequenceFile.Writer writer;
    public SequenceFile.Reader reader;
    public SecuenceFile() {
        super();        
    }

    public static void main(String[] args) {
        SecuenceFile s=new SecuenceFile();
        s.inicia();

    }
    public void inicia()
    {
        this.filePath=new Path("borrarSecuence.txt"); //user/javier/borrar.txt
        guardar(this.filePath);
          leer(this.filePath);
    }
public void guardar(Path filePath)
{
    try {
          //   writer = SequenceFile.createWriter(fs, conf,filePath, Long.class,
                   //   String.class);           
             writer = SequenceFile.createWriter(conf,
                     Writer.file(filePath), Writer.keyClass(Text.class),
                     Writer.valueClass(IntWritable.class));       

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        try {           

            writer.append(new Text("key1"), new IntWritable(1));
            writer.append(new Text("key2"), new IntWritable(2));    
            writer.append(new Text("key3"), new IntWritable(3));
            writer.append(new Text("key4"), new IntWritable(4));
            writer.append(new Text("key5"), new IntWritable(5));
            writer.append(new Text("key6"), new IntWritable(6));    
            writer.append(new Text("key7"), new IntWritable(7));
            writer.append(new Text("key8"), new IntWritable(8));
            writer.close();
         //   IOUtils.closeStream(writer);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
}
public void leer(Path filePath)
{
    try {       
        reader = new SequenceFile.Reader(conf,
                Reader.file(filePath));
        Text key = new Text();
        IntWritable val = new IntWritable();

        while (reader.next(key, val)) {
            System.err.println(key + "\t" + val);
        }

    reader.close();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
  }
}

введите описание изображенияздесь

Я использую hadoop-eclipse-plugin-2.6.0.jar, Hadoop 2.9.2, Java-версия "1.8.0_191", eclipse Oxigen

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...