Hadoop编程 在HDFS里新建文件并写入内容,以及输出
2016-12-12 21:25
513 查看
package zq; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataOutputStream; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; public class Write { public static void main(String[] args) throws IOException { Configuration conf=new Configuration(); conf.set("fs.default.name", "hdfs://localhost:9000"); Path inFile =new Path("/user/hadoop/hadoopfile/t1"); FileSystem hdfs=FileSystem.get(conf); FSDataOutputStream outputStream=hdfs.create(inFile); outputStream.writeUTF("china cstor cstor china"); outputStream.flush(); outputStream.close(); } }
输出HDFS里刚写入文件的内容:
package output; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FSDataOutputStream; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; public class Read { public static void main(String[] args) throws IOException { Configuration conf=new Configuration(); conf.set("fs.default.name", "hdfs://localhost:9000"); Path inFile =new Path("/user/hadoop/hadoopfile/t1"); FileSystem hdfs=FileSystem.get(conf); FSDataInputStream inputStream=hdfs.open(inFile); System.out.println("myfile:"+inputStream.readUTF()); inputStream.close(); } }
相关文章推荐
- Hadoop编程在HDFS里新建文件并写入内容,以及输出
- linux shell编程之文件内容写入和日志记录
- 将输入文件读入字符串以及将字符串写入输出文件
- 安装配置Hadoop的各个配置文件修改的地方以及修改的内容
- java中的文件读取和文件写出:如何从一个文件中获取内容以及如何向一个文件中写入内容
- [Hadoop]HDFS文件的相关操作(上传、新建、删除和重命名)
- 将MySQL输出内容写入(重定向到)文件
- MapReduce中,new Text()引发的写入HDFS的输出文件多一列的问题
- 安装配置Hadoop的各个配置文件修改的地方以及修改的内容
- Hadoop中HDFS写入文件的原理剖析
- 安装、进程-云计算学习笔记---hadoop的简介,以及安装,用命令实现对hdfs系统进行文件的上传下载-by小雨
- 文件读取,写入(去除源文件内容)以及追加写入(保留原文件内容)
- linux shell编程之文件内容写入和日志记录 推荐
- 新建一个txt文件,写入文件内容,…
- python给文件写入/追加内容时输出x00和乱码的问题
- PHP新建文件并写入内容demo
- Hadoop向HDFS写入、删除、读取文件
- Hadoop学习全程记录——hadoop读取hdfs文件系统里的内容