Hadoop HDFS的一些操作(2)

上传一个文件到HDFS

命令:user@namenode:Hadoop$ bin/hadoop dfs -put 文件名 /user/yourUserName/

使用hadoop API

// 上传文件到HDFS 
    public void PutFile(Configuration conf, String srcFile, String dstFile) { 
        try { 
            FileSystem hdfs = FileSystem.get(conf); 
            Path srcPath = new Path(srcFile); 
            Path dstPath = new Path(dstFile); 
            hdfs.copyFromLocalFile(srcPath, dstPath); 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } 
    }

从 HDFS 中导出数据

命令:user@namenode:hadoop$ bin/hadoop dfs -cat foo

使用hadoop API

// 从HDFS读取文件 
    public void ReadFile(Configuration conf, String FileName) { 
        try { 
            FileSystem hdfs = FileSystem.get(conf); 
            FSDataInputStream dis = hdfs.open(new Path(FileName)); 
            IOUtils.copyBytes(dis, System.out, 4096, false); 
            dis.close(); 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } 
    }

HDFS 的关闭

命令:user@namenode:hadoop$ bin/stop-dfs.sh

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:http://www.heiqu.com/2127c035ad480601643f0cc380234ef7.html