1. 程式人生 > >關於hadoop HDFS進行讀寫文件操作的問題

關於hadoop HDFS進行讀寫文件操作的問題

close config system inf () str on() exception oca

問題 : java無法鏈接 報錯顯示被拒絕鏈接 剛開始一直以為是自己hadoop沒有配好(或者自己的jar包沒有導入好),開始就走偏了導致時間浪費

原因是:hadoop沒有開起來........

一個讀寫的代碼如下

package com;
import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

public class NanShou { public static void main(String[] args) throws IOException { //HDFS連接 Configuration conf=new Configuration(); FileSystem fs = FileSystem.get(conf); //要求1 fs.mkdirs(new Path("/usr/local/hadoop/l"));//建立文件夾 Path inFile1 =new Path("/usr/local/hadoop/l/hdfstest1.txt
");//創建文本hdfstest1.txt FSDataOutputStream outputStream1=fs.create(inFile1); outputStream1.writeUTF("信1605-1 20163678 胡 HDFS課堂測試");//輸入 outputStream1.flush(); outputStream1.close(); //要求2 Path inFile2=new Path("/usr/local/hadoop/l/hdfstest2.txt");//創建文本hdfstest2.txt FSDataOutputStream outputStream2=fs.create(inFile2); FSDataInputStream inputStream1
=fs.open(inFile1);//打開hdfstest1.txt outputStream2.writeUTF(inputStream1.readUTF());//讀取hdfstest1.txt內容並寫入hdfstest2.txt outputStream2.flush(); outputStream2.close(); inputStream1.close(); //要求3 FSDataInputStream inputStream2=fs.open(inFile2);//打開hdfstest2.txt System.out.println(inputStream2.readUTF());//輸出//打開hdfstest2.txt內容 inputStream2.close(); } }

關於hadoop HDFS進行讀寫文件操作的問題