Hdfs readline

转载地址：http://dacoolbaby.iteye.com/blog/1955427

一致疏于JAVA IO方面的基础学习。

这次在使用到HDFS的文件接口的时候，就遇到这方面的问题。

于是巩固一下基础。

java io是典型的decorator设计模式。

Path path = new Path(“路径”);

FSDataIOutputStream fdos = fs.append(path); //追加

fdos.write……即可

fdos.flush();//刷出数据

  

FSDataInputStream fdis = fs.open(path);

 

Text line = new Text();

LineReader reader = new LineReader(fdis); //一行一行的读 使用LineReader

while(reader.readLine(line) > 0) {

         System.out.println(line);//输出

} 

fdis.close();

 

使用bufferedReader读取

 String uri = "hdfs://localhost:9000/hadoop/test/IP-COUNTRY-REGION-CITY.CSV.hive"; 

Configuration conf = new Configuration(); 
FileSystem fs = null; 
FSDataInputStream in = null; 
BufferedReader d = null; 

try { 
    fs = FileSystem.get(URI.create(uri), conf); 
    in = fs.open(new Path(uri)); 
    d = new BufferedReader(new InputStreamReader(in));   //使用BufferedReader 进行readLine
    String s = null; 
    int stat = 1; 
    while (true) { 
        System.out.println("line "+stat++); 
        s = d.readLine();

    public class JavaFile01 {  
      
    //InputStream 三个基本的读方法          
    //abstract int read() ：读取一个字节数据，并返回读到的数据，如果返回-1，表示读到了输入流的末尾。          
    //int read(byte[] b) ：将数据读入一个字节数组，同时返回实际读取的字节数。如果返回-1，表示读到了输入流的末尾。          
    //int read(byte[] b, int off, int len) ：将数据读入一个字节数组，同时返回实际读取的字节数。  
    //如果返回-1，表示读到了输入流的末尾。  
    //off指定在数组b中存放数据的起始偏移位置；  
    //len指定读取的最大字节数。  
      
        public static void main(String[] args) throws IOException {  
      
        File f = new File("a.txt");  
        //InputStream是一个标准的输入接口  
        //对应读取数据的类有：FileInputStream ObjectInputStream等  
          
        //XXXInputStream就是为InputStream对象赋予额外的功能，  
        InputStream in = new BufferedInputStream(new FileInputStream(f));  
        byte[] b = new byte[1024];  
        while(in.read()!=-1){  
            try {  
            in.read(b);  
            System.out.println("读入buffer的信息："+new String(b));  
            } catch (IOException e) {  
            e.printStackTrace();  
            }  
        }  
          
    //  InputSteream和OutpurStream是针对基于字节（byte）输入输出设计的，实际应用中常常需要读  
    //  写的是基于字符（char ,Unicode 2 个字节）的，java.io.Reader和java.io.Writer就是所有读  
    //  写字符数据流的父类。  
          
        //FileReader作为Reader对象的数据源  
        BufferedReader brin = new BufferedReader(new FileReader("a.txt"));  
          
          
        //Stream与Reader之间的转换  
        InputStreamReader isr = new InputStreamReader(in);//<--Stream输入  
        BufferedReader reader = new BufferedReader(isr);//使用Reader进行读取  
        System.out.println(reader.readLine());  
        }  
      
    }