HDFS的java接口——简化HDFS文件系统操作
2017-07-26 14:16
330 查看
package com.quanttech;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
/**
* @topic HDFS文件操作工具类
* @author ZhouJ
*
*/
public class HdfsUtils {
/*
* 判断HDFS目录是否存在路径path
*/
public static boolean isExists(Configuration conf, String path) throws Exception {
FileSystem fs = FileSystem.get(conf);
return fs.exists(new Path(path));
}
/*
* 删除HDFS的一个目录或者文件
*/
public static void Delete(Configuration conf, String path) throws Exception {
FileSystem fs = FileSystem.get(conf);
fs.delete(new Path(path), true);
}
/*
* 创建一个HDFS目录
*/
public static void Mkdir(Configuration conf, String path) throws Exception {
FileSystem fs = FileSystem.get(conf);
if(fs.mkdirs(new Path(path))){
System.out.println("HDFS目录:"+path+"创建成功!");
}
}
}
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
/**
* @topic HDFS文件操作工具类
* @author ZhouJ
*
*/
public class HdfsUtils {
/*
* 判断HDFS目录是否存在路径path
*/
public static boolean isExists(Configuration conf, String path) throws Exception {
FileSystem fs = FileSystem.get(conf);
return fs.exists(new Path(path));
}
/*
* 删除HDFS的一个目录或者文件
*/
public static void Delete(Configuration conf, String path) throws Exception {
FileSystem fs = FileSystem.get(conf);
fs.delete(new Path(path), true);
}
/*
* 创建一个HDFS目录
*/
public static void Mkdir(Configuration conf, String path) throws Exception {
FileSystem fs = FileSystem.get(conf);
if(fs.mkdirs(new Path(path))){
System.out.println("HDFS目录:"+path+"创建成功!");
}
}
}
相关文章推荐
- HDFS的java接口——简化HDFS文件系统操作
- java实现对hdfs文件系统的上传,下载,删除,创建文件夹的操作演示
- 排坑!java操作hadoop中的hdfs文件系统
- JAVA API操作HDFS文件系统
- java操作hdfs文件系统上的文件
- java操作HDFS文件系统
- HDFS文件系统在JAVA中的操作(1) 读取文件
- hdfs文件系统中相互复制的java操作
- HDFS文件系统简单的Java读写操作
- HDFS文件系统操作JAVA-API
- JAVA API操作HDFS文件系统
- 文件操作的系统调用接口
- Hadoop HDFS文件操作 Java实现类
- Hadoop HDFS文件操作 Java实现类
- HDFS 文件系统操作
- Hadoop HDFS文件操作的Java代码
- JAVA实现:将文件从本地上传到HDFS上、从HDFS上读取等操作
- 访问Hadoop的HDFS文件系统的Java实现
- 利用java操作Hadoop文件 /hdfs
- 通过JAVA API操作HDFS文件系统