public static void moveFilesToDirectory(String hdfsUrl, String sourceDirectory, String targetDirectory) throws IOException {
		Configuration conf = new Configuration();
		conf.set("fs.default.name", hdfsUrl);
		conf.set("hadoop.job.ugi", DEFAULT_UGI);
		FileSystem fileSystem = FileSystem.get(conf);
		FileStatus[] statuses = fileSystem.listStatus(new Path(sourceDirectory));
		for (int i = 0; i < statuses.length; i++) {
			FileStatus fileStatus = statuses[i];
			if (!isDirectory(fileSystem, targetDirectory)) {
				logger.info("HDFS에 [" + targetDirectory + "] 디렉토리가 존재하지 않아서 생성합니다.");
				fileSystem.mkdirs(new Path(targetDirectory));
			}
			fileSystem.rename(fileStatus.getPath(), new Path(targetDirectory));
			logger.info("HDFS의 파일 [" + fileStatus.getPath() + "]을 [" + targetDirectory + "] 디렉토리로 이동했습니다.");
		}
	}