一、写文件
// 获取文件系统客户端FileSystem实例 FileSystem fs = FileSystem.Factory.get(); // 构造Alluxio路径AlluxioURI实例 AlluxioURI path = new AlluxioURI("/myFile"); // 设置一些操作选项 // 设置文件块大小为128M CreateFileOptions options = CreateFileOptions.defaults().setBlockSize(128 * Constants.MB); // 创建一个文件并获取它的文件输出流FileOutStream实例 FileOutStream out = fs.createFile(path); // 调用文件输出流FileOutStream实例的write()方法写入数据 out.write(...); // 关闭文件输出流FileOutStream实例,结束写文件操作 out.close();
二、读文件
// 获取文件系统客户端FileSystem实例 FileSystem fs = FileSystem.Factory.get(); // 构造Alluxio路径AlluxioURI实例 AlluxioURI path = new AlluxioURI("/myFile"); // 打开一个文件,获得文件输入流FileInStream(同时获得一个锁以防止文件被删除) FileInStream in = fs.openFile(path); // 调用文件输入流FileInStream实例的read()方法读数据 in.read(...); // 关闭文件输入流FileInStream实例,结束读文件操作(同时释放锁) in.close();