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+"创建成功！");

        }

    }

}