13518219792
这期内容当中小编将会给大家带来有关java对hdfs的操作是怎样的，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
员工经过长期磨合与沉淀，具备了协作精神，得以通过团队的力量开发出优质的产品。创新互联坚持“专注、创新、易用”的产品理念，因为“专注所以专业、创新互联网站所以易用所以简单”。公司专注于为企业提供成都网站制作、网站设计、微信公众号开发、电商网站开发，微信小程序开发，软件按需制作网站等一站式互联网企业服务。
package hdfs;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
/**
* java对hdfs的操作
* @author 林
*
*/
public class App2 {
public static final String HDFS_PATH = "hdfs://hadoop:9000";
public static final String DRI_PATH = "/d1000";
public static final String FILE_PATH = "/d1000/f1000";
public static void main(String[] args) throws Exception {
FileSystem fileSystem = FileSystem.get(new URI(HDFS_PATH),new Configuration());
//创建文件夹
mkDri(fileSystem);
//上传文件
uploadDate(fileSystem);
//下载文件
downloadFile(fileSystem);
//删除文件
deleteFile(fileSystem);
}
public static void deleteFile(FileSystem fileSystem) throws IOException {
fileSystem.delete(new Path(FILE_PATH), true);
}
//下载文件
public static void downloadFile(FileSystem fileSystem) throws IOException {
FSDataInputStream in = fileSystem.open(new Path(FILE_PATH));
FileOutputStream out = new FileOutputStream(new File("D:/copy.txt"));
//IOUtils.copyBytes(in, System.out, 2048, true);下载到控制台
IOUtils.copyBytes(in,out, 2048, true);
}
//上传文件
public static void uploadDate(FileSystem fileSystem) throws IOException,
FileNotFoundException {
FSDataOutputStream out = fileSystem.create(new Path(FILE_PATH));
FileInputStream in = new FileInputStream("D:/hadoop安装.txt");
IOUtils.copyBytes(in, out, 1024,true);
}
//创建目录
public static void mkDri(FileSystem fileSystem) throws IOException {
fileSystem.mkdirs(new Path(DRI_PATH));
}
}上述就是小编为大家分享的java对hdfs的操作是怎样的了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。
