HDFS 断点续传，写文件功能

实际上这是个 HDFS 的工具类部分代码。 首先

public static Configuration configuration = null;public static FileSystem fileSystem = null;static {try {if (null == configuration) {configuration = new Configuration();}if (null == fileSystem) {fileSystem = FileSystem.get(URI.create(RockyConstants.HDFS_PATH), configuration);}} catch (IOException e) {e.printStackTrace();}}/*** 整文件存入 HDFS** @throws Exception*/public static boolean putHDFS(String filePath, byte[] info) {try {FSDataOutputStream writer = fileSystem.create(new Path(filePath), true);writer.write(info);writer.flush();writer.close();} catch (IOException e) {e.printStackTrace();return false;}return true;}

/*** 断点续传存入* @throws IOException*/public static void continueUpload(String targetPath, byte[] info) throws IOException{Path fsPath = new Path(targetPath);// 第一次if (!fileSystem.exists(fsPath)) {putHDFS(targetPath,info);} else {// 续传FSDataOutputStream writer = fileSystem.append(fsPath);writer.write(info);writer.flush();writer.close();}}