更新时间:2024-06-14 GMT+08:00
写HDFS文件
功能简介
写文件过程为:
- 实例化一个FileSystem。
- 由此FileSystem实例获取写文件的各类资源。
- 将待写内容写入到HDFS的指定文件中。
在写完文件后,需关闭所申请资源。
代码样例
如下是写文件的代码片段,详细代码请参考com.huawei.bigdata.hdfs.examples中的HdfsMain类和HdfsWriter类。
/** * 创建文件,写文件 * * @throws IOException * @throws ParameterException */ private void write() throws IOException, ParameterException { final String content = "hi, I am bigdata. It is successful if you can see me."; InputStream in = (InputStream) new ByteArrayInputStream( content.getBytes()); try { HdfsWriter writer = new HdfsWriter(fSystem, DEST_PATH + File.separator + FILE_NAME); writer.doWrite(in); System.out.println("success to write."); } finally { //务必要关闭流资源 close(in); } }
父主题: 开发HDFS应用