Java执行hadoop的基本操作实例代码

public static void uploadInputFile(String localFile) throws IOException{    Configuration conf = new Configuration();    String hdfsPath = "hdfs://localhost:9000/";    String hdfsInput = "hdfs://localhost:9000/user/hadoop/input";    FileSystem fs = FileSystem.get(URI.create(hdfsPath), conf);    fs.copyFromLocalFile(new Path(localFile), new Path(hdfsInput));    fs.close();    System.out.println("已经上传文件到input文件夹啦");  }