当前位置： 移动技术网 > IT编程>开发语言>Java > JAVA操作HDFS案例的简单实现

JAVA操作HDFS案例的简单实现

2019年07月19日  | 移动技术网IT编程  | 我要评论

本文介绍了java操作hdfs案例的简单实现，分享给大家，也给自己做个笔记

jar包引入，pom.xml：

<dependency> 
 <groupid>org.apache.hadoop</groupid> 
 <artifactid>hadoop-common</artifactid> 
 <version>2.8.0</version> 
</dependency> 
<dependency> 
 <groupid>org.apache.hadoop</groupid> 
 <artifactid>hadoop-hdfs</artifactid> 
 <version>2.8.0</version> 
</dependency>

将本地文件上传到hdfs服务器:

/** 
 * 上传文件到hdfs上 
 */ 
@test 
public void upload() throws ioexception { 
  configuration conf = new configuration(); 
  conf.set("fs.defaultfs","hdfs://hzq:9000"); 
  filesystem fs = filesystem.get(conf); 
  fs.copyfromlocalfile(new path("/home/hzq/jdk1.8.tar.gz"),new path("/demo")); 
}

解析：

在开发中我没有引入“core-site.xml”配置文件，所以在本地调用时使用conf进行配置“conf.set("fs.defaultfs","hdfs://hzq:9000");“，下面雷同。

将hdfs上文件下载到本地：

/** 
 * 将hdfs上文件下载到本地 
 */ 
@test 
public void download() throws ioexception { 
  configuration conf = new configuration(); 
  conf.set("fs.defaultfs","hdfs://hzq:9000"); 
  filesystem fs = filesystem.newinstance(conf); 
  fs.copytolocalfile(new path("/java/jdk1.8.tar.gz"),new path("/home/hzq/")); 
}

删除hdfs上指定文件：

/** 
 * 删除hdfs上的文件 
 * @throws ioexception 
 */ 
@test 
public void removefile() throws ioexception { 
  configuration conf = new configuration(); 
  conf.set("fs.defaultfs","hdfs://hzq:9000"); 
  filesystem fs = filesystem.newinstance(conf); 
  fs.delete(new path("/demo/jdk1.8.tar.gz"),true); 
}

在hdfs上创建文件夹：

/** 
 * 在hdfs更目录下面创建test1文件夹 
 * @throws ioexception 
 */ 
@test 
public void mkdir() throws ioexception { 
  configuration conf = new configuration(); 
  conf.set("fs.defaultfs","hdfs://hzq:9000"); 
  filesystem fs = filesystem.newinstance(conf); 
  fs.mkdirs(new path("/test1")); 
}

列出hdfs上所有的文件或文件夹：

@test 
  public void listfiles() throws ioexception { 
    configuration conf = new configuration(); 
    conf.set("fs.defaultfs","hdfs://hzq:9000"); 
    filesystem fs = filesystem.newinstance(conf); 
    // true 表示递归查找 false 不进行递归查找 
    remoteiterator<locatedfilestatus> iterator = fs.listfiles(new path("/"), true); 
    while (iterator.hasnext()){ 
      locatedfilestatus next = iterator.next(); 
      system.out.println(next.getpath()); 
    } 
    system.out.println("----------------------------------------------------------"); 
    filestatus[] filestatuses = fs.liststatus(new path("/")); 
    for (int i = 0; i < filestatuses.length; i++) { 
      filestatus filestatus = filestatuses[i]; 
      system.out.println(filestatus.getpath()); 
    } 
  }

运行结果：

                                    

结果分析：

“listfiles“列出的是hdfs上所有文件的路径，不包括文件夹。根据你的设置，支持递归查找。

  ”liststatus“列出的是所有的文件和文件夹，不支持递归查找。如许递归，需要自己实现。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网