入门案例

Last updated: ... / Reads: 34 Edit

使用Java API操作HDFS可以提供更灵活和定制化的功能。下面是一些示例代码,演示了如何使用Java API进行常见的HDFS操作: 创建一个Hadoop配置对象: Configuration conf = new Configuration(); conf.set("fs.defaultFS", "hdfs://localhost:9000"); // 设置HDFS的地址

创建一个FileSystem对象来与HDFS交互: FileSystem fs = FileSystem.get(conf); 检查文件或目录是否存在: Path path = new Path("/path/to/file"); boolean exists = fs.exists(path); 创建目录: Path dirPath = new Path("/path/to/directory"); fs.mkdirs(dirPath); 上传文件到HDFS: Path srcPath = new Path("/path/to/local/file"); Path destPath = new Path("/path/to/hdfs/destination"); fs.copyFromLocalFile(srcPath, destPath); 下载文件从HDFS到本地: Path hdfsPath = new Path("/path/to/hdfs/file"); Path localPath = new Path("/path/to/local/destination"); fs.copyToLocalFile(hdfsPath, localPath); 删除文件或目录: Path deletePath = new Path("/path/to/delete"); fs.delete(deletePath, true); // 第二个参数表示是否递归删除目录 这只是一小部分可用的API操作示例,你可以根据自己的需求进一步探索和使用HDFS的Java API。记得在使用完毕后关闭FileSystem对象: fs.close(); 希望这些示例能够帮助你开始使用Java API操作HDFS!


Comments

Make a comment