Hadoop学习--FileUtil工具类使用--day04
2017-01-03 15:08
134 查看
import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.net.URL;
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.FsUrlStreamHandlerFactory;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
import org.junit.Test;
public class append {
/**
* 通过API实现append追加操作
*
* @author Administrator
*
* [hadoop@hadoop01 ~]$ hdfs dfs -chmod -R a+w /user/hadoop
* [hadoop@hadoop01 ~]$ hdfs dfs -ls -R /
*
*
*/
@Test
public void appendfile() throws Exception {
//创建configuration对象,有个默认的加载顺序,先从core-default.xml,再到src目录中的文件,这里
//我们给定了
Configuration conf = new Configuration();
//通过conf的configuration对象创建了该分布式文件系统fs,默认如果不指定文件的话为本地文件系统
FileSystem fs = FileSystem.get(conf);
//定义一个URL的字符串
String file = "hdfs://hadoop01:9000/user/hadoop/data/hello.txt";
//通过一个URL的字符串构建一个path对象
Path path = new Path(file);
FSDataOutputStream out = fs.append(path);
out.writeChars("chuck\r\n");
System.out.println(out.toString());
out.close();
}
}
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.net.URL;
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.FsUrlStreamHandlerFactory;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
import org.junit.Test;
public class append {
/**
* 通过API实现append追加操作
*
* @author Administrator
*
* [hadoop@hadoop01 ~]$ hdfs dfs -chmod -R a+w /user/hadoop
* [hadoop@hadoop01 ~]$ hdfs dfs -ls -R /
*
*
*/
@Test
public void appendfile() throws Exception {
//创建configuration对象,有个默认的加载顺序,先从core-default.xml,再到src目录中的文件,这里
//我们给定了
Configuration conf = new Configuration();
//通过conf的configuration对象创建了该分布式文件系统fs,默认如果不指定文件的话为本地文件系统
FileSystem fs = FileSystem.get(conf);
//定义一个URL的字符串
String file = "hdfs://hadoop01:9000/user/hadoop/data/hello.txt";
//通过一个URL的字符串构建一个path对象
Path path = new Path(file);
FSDataOutputStream out = fs.append(path);
out.writeChars("chuck\r\n");
System.out.println(out.toString());
out.close();
}
}
相关文章推荐
- Hadoop学习--FileUtil工具类使用--day04
- Hadoop学习与使用之基本操作命令
- Hadoop学习笔记之五:使用Eclipse插件
- Hadoop学习笔记之五:使用Eclipse插件
- Hadoop学习--HBase与MapReduce的使用
- Hadoop学习记录(4)|MapReduce原理|API操作使用
- hadoop学习--安装使用
- hadoop学习笔记1.使用shell和JAVA API操作HDFS
- 【hadoop】Hadoop学习笔记(九):如何在windows上使用eclipse远程连接hadoop进行程序开发
- 【hadoop】Hadoop学习笔记(八):如何使用Maven构建《hadoop权威指南3》随书的源码包
- hadoop学习笔记之mapreduce中使用hbase
- 【java学习】Jni在hadoop上的使用(上)
- Hadoop学习笔记(八):如何使用Maven构建《hadoop权威指南3》随书的源码包
- Hadoop学习笔记(七):使用distcp并行拷贝大数据文件
- 我的Java开发学习之旅------>工具类:Java使用正则表达式分离出字符串中的中文和英文
- 开始hadoop前的准备:ubuntu学习笔记-基本环境的搭建(ssh的安装,SecureCRT连接,vim的安装及使用、jdk的安装)
- Hadoop编程学习(四):使用FileSystem类进行文件读写及查看文件信息
- hadoop学习之-使用ODCH工具实现oralce外部表访问HDFS数据文件
- hadoop学习笔记之-使用bind配置DNS实验 .
- Hadoop学习----直接使用FileSystem以标准输出格式显示Hadoop文件系统中的文件