使用Java API对HDFS进行如下操作：文件的创建、上传、下载以及删除等操作-Toy模板网

这篇具有很好参考价值的文章主要介绍了使用Java API对HDFS进行如下操作：文件的创建、上传、下载以及删除等操作。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

HDFS-JAVA接口:上传文件

将一个本地文件（无具体要求）上传至HDFS中的/hdfs-test路径下（如无此路径，新建一个）。

新建路径：

java上传文件至hdfs,java,hdfs,hadoop

首先在路径/usr/test/ 下新建test.txt，指令为：/usr/test/test.txt，然后进行上传操作。

package org.apache.hadoop.examples;
import java.io.FileInputStream;
public class module_info {

	public static void main(String[] args) throws Exception {
		Configuration conf=new Configuration();
		URI uri=new URI("hdfs://192.168.46.xxx:9000");
		FileSystem fs=FileSystem.get(uri,conf,"hadoop");
		Path src=new Path("/usr/test/test.txt");
		Path dst=new Path("/hdfs-test/test.txt");
		fs.copyFromLocalFile(src, dst);
		fs.close();
		System.out.println("Upload Successfully!");
		// TODO Auto-generated method stub

	}

}

2.HDFS-JAVA接口:创建文件

在HDFS中的/hdfs-test路径下新建一个data.txt文件。

package org.apache.hadoop.examples1;
import java.io.FileInputStream;
public class CreateText {
	public static void main(String[] args) throws Exception{ 
		// TODO Auto-generated method stub
		Configuration conf = new Configuration();
		URI uri = new URI("hdfs://192.168.46.xxx:9000");
		FileSystem fs = FileSystem.get(uri, conf, "hadoop");
		Path path = new Path("/hdfs-test/data.txt");
		FSDataOutputStream newFile = fs.create(path, true); 
		newFile.writeBytes("hello"); 
		newFile.close(); 
		fs.close();
	}
}

查询发现/hdfs-test路径下新建了一个data.txt文件

java上传文件至hdfs,java,hdfs,hadoop

输入指令查看文件内容

java上传文件至hdfs,java,hdfs,hadoop

3.HDFS-JAVA接口:下载文件

将HDFS中的/hdfs-test/data.txt文件下载到本地任一路径下。

package org.apache.hadoop.examples;
import java.net.URI;
public class DownloadText {
	public static void main(String[] args) throws Exception {
		Configuration conf=new Configuration();
		URI uri=new URI("hdfs://192.168.46.xxx:9000");
		FileSystem fs=FileSystem.get(uri,conf,"hadoop");
		Path src=new Path("/hdfs-test/data.txt");
		Path dst=new Path("/usr/test/data.txt");
		fs.copyToLocalFile(false,src,dst,true);
		fs.close();
		System.out.println("Download Successfully!");
		// TODO Auto-generated method stub
	}
}

根据路径/usr/test/data.txt查看内容，发现下载的文件data.txt

java上传文件至hdfs,java,hdfs,hadoop

4.HDFS-JAVA接口:删除文件

将HDFS中/hdfs-test路径下的data.txt删除。文章来源地址https://www.toymoban.com/news/detail-724019.html

package org.apache.hadoop.examples;
import java.net.URI;

public class DeleteTxt {
	
	public static void main(String[] args) throws Exception {
		Configuration conf=new Configuration();
		URI uri=new URI("hdfs://192.168.46.xxx:9000");
		FileSystem fs=FileSystem.get(uri,conf,"hadoop");
		Path path=new Path("/hdfs-test/data.txt");
		fs.delete(path);
		fs.close();
		System.out.println("Delete File Successdully!");
		
		// TODO Auto-generated method stub
	}
}

到了这里，关于使用Java API对HDFS进行如下操作：文件的创建、上传、下载以及删除等操作的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！