提供一个HDFS内的文件的路径,对该文件进行创建和删除操作。如果文件所在目录不存在,则自动创建目录。

import java.text.SimpleDateFormat;

import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocatedFileStatus;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.RemoteIterator;


public class F_CreateAndDel {
    public static void CreateFile(FSDataOutputStream out,FileSystem fs,Path p_remotepath)
    {
        try{
            out = fs.create(p_remotepath);
            System.out.println("create successfully");
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }
    public static void DelFile(FileSystem fs,Path p_remotepath)
    {
        try{
            if(fs.delete(p_remotepath, true))
            {
                System.out.println("del successfully");
            }
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }
    public static void main(String arg[])
    {
        try{
            Var_init var = new Var_init();
            if(!var.fs.exists(var.p_remoteFilePath))
                CreateFile(var.out,var.fs,var.p_remoteFilePath);
            else
            {
                DelFile(var.fs,var.p_remoteFilePath);
            }
        }
        catch(Exception e){
            e.printStackTrace();
        }
    }

}

Var_init类参考 https://www.cnblogs.com/MiraculousB/p/13848744.html