// 判断output文件夹是否存在,如果存在则删除 Path outPath = new Path("hdfs://192.168.9.13:8020/meanwhileFind");// 输出路径 FileSystem fs = outPath.getFileSystem(conf);// 根据输出路径找到文件,参数为配置文件 if (fs.exists(outPath)) { fs.delete(outPath); // fs.delete(outPath, true);true的意思是,就算output有东西,也一带删除,默认为true } FileInputFormat.setInputPaths(job, new Path("hdfs://192.168.9.13:8020/gradeMarking")); FileOutputFormat.setOutputPath(job, outPath);
时间: 2024-11-11 20:22:39