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