zoukankan      html  css  js  c++  java
  • java阅读器hdfs单纯demo

    周围环境:eclipse + eclipse hadoop插入。 hadoop + rhel6.4

    package test;
    
    import java.io.IOException;
    import java.net.URI;
    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.fs.FileSystem;
    import org.apache.hadoop.fs.Path; 
    import org.apache.hadoop.fs.FSDataInputStream;
    import org.apache.hadoop.fs.FSDataOutputStream;;
    
    public class Test {
    	
    	
    	public void WriteFile(String hdfs) throws IOException {
    		Configuration conf = new Configuration();
    		FileSystem fs = FileSystem.get(URI.create(hdfs),conf);
    		FSDataOutputStream hdfsOutStream = fs.create(new Path(hdfs));
    		hdfsOutStream.writeChars("hello");
    		hdfsOutStream.close();
    		fs.close();		
    	}
    	
    	public void ReadFile(String hdfs) throws IOException {
    		Configuration conf = new Configuration();
    		FileSystem fs = FileSystem.get(URI.create(hdfs),conf);
    		FSDataInputStream hdfsInStream = fs.open(new Path(hdfs));
    		
    		byte[] ioBuffer = new byte[1024];
    		int readLen = hdfsInStream.read(ioBuffer);
    		while(readLen!=-1)
    		{
    			System.out.write(ioBuffer, 0, readLen);
    			readLen = hdfsInStream.read(ioBuffer);
    		}
    		hdfsInStream.close();
    		fs.close();	
    	}
    		
    	public static void main(String[] args) throws IOException {		
    		String hdfs = "hdfs://192.168.56.112:9000/test/hello.txt";
    		Test t = new Test();		
    		t.WriteFile(hdfs);
    		t.ReadFile(hdfs);
    	  }
    }
    


     

    版权声明:本文博主原创文章,博客,未经同意不得转载。

  • 相关阅读:
    多文件编程(day13)
    字符串函数(day11)
    字符编码
    逻辑公式相等的自动证明
    排列组合问题之圆形分布
    排列组合之线性排列
    分金条
    进制的意义和算法
    集合的异或运算(对称差)
    集合习题之列出有限集合所有子集
  • 原文地址:https://www.cnblogs.com/mengfanrong/p/4821403.html
Copyright © 2011-2022 走看看