我试图逐行读取hdfs文件，然后创建一个hdfs文件并逐行写入。我使用的代码如下所示：

Path FileToRead=new Path(inputPath);
        FileSystem hdfs = FileToRead.getFileSystem(new Configuration());            
        FSDataInputStream fis = hdfs.open(FileToRead);
        BufferedReader reader = new BufferedReader(new InputStreamReader(fis));

        String line;
            line = reader.readLine(); 
            while (line != null){

                String[] lineElem = line.split(",");
                for(int i=0;i<10;i++){

                    MyMatrix[i][Integer.valueOf(lineElem[0])-1] = Double.valueOf(lineElem[i+1]);
                }

                line=reader.readLine();
        } 

        reader.close();
        fis.close();

        Path FileToWrite = new Path(outputPath+"/V"); 
        FileSystem fs = FileSystem.get(new Configuration());
        FSDataOutputStream fileOut = fs.create(FileToWrite);
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(fileOut));
        writer.write("check");
        writer.close();
        fileOut.close();

当我在outputpath中运行此代码时，尚未创建文件v。但是，如果我用写文件的部分替换读文件的部分，文件将被创建，并且check被写入其中。有谁能帮助我理解如何正确使用它们，以便能够先读取整个文件，然后逐行写入文件？
我也尝试了另一个代码从一个文件读取和写入到另一个文件，但该文件将被创建，但没有写入它！
我用这样的东西：

hadoop jar main.jar program2.Main input output

然后，在我的第一个作业中，我使用map reduce类从arg[0]读取并写入args[1]+“/newv”中的文件，它可以正常工作。在我的另一个类（非map reduce）中，我使用args[1]+“/newv”作为输入路径，使用output+“/v\u 0”作为输出路径（我将这些字符串传递给构造函数）。下面是该类的代码：

public class Init_V {

String inputPath, outputPath;

public Init_V(String inputPath, String outputPath) throws Exception {

    this.inputPath = inputPath;
    this.outputPath = outputPath;

    try{            

        FileSystem fs = FileSystem.get(new Configuration());
        Path FileToWrite = new Path(outputPath+"/V.txt"); 
        Path FileToRead=new Path(inputPath);
        BufferedWriter output = new BufferedWriter
         (new OutputStreamWriter(fs.create(FileToWrite,
                 true)));  

        BufferedReader reader = new
            BufferedReader(new InputStreamReader(fs.open(FileToRead)));
                 String data;
                 data = reader.readLine();
                 while ( data != null ) 
                 {
                     output.write(data);
                     data = reader.readLine();
                 }
                 reader.close();                     
                 output.close(); }catch(Exception e){
}

}

}