标签：24 fs java hadoop io new import

经过种种调试，Hadoop可以用了。

package hadoop;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;

import java.io.FileInputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URI;

public class upload {
public static void main(String[] args) throws Exception{
FileSystem fs = FileSystem.get(new URI("hdfs://localhost/:8020"),new Configuration(),"root");
InputStream in = new FileInputStream("D://text.txt");
OutputStream out = fs.create(new Path("/text.txt"));
IOUtils.copyBytes(in,out,4096,true);
System.out.println("上传Hadoop文件成功!");
}

}

package hadoop;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;

import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URI;

public class download {
public static void main(String[] args) throws Exception{
FileSystem fs = FileSystem.get(new URI("hdfs://localhost/:8020"),new Configuration());
InputStream is = fs.open(new Path("/text.txt"));
OutputStream out = new FileOutputStream("D://JAVA/text.txt");
IOUtils.copyBytes(is,out,4096,true);
System.out.println("下载完成");
}
}

标签：24,fs,java,hadoop,io,new,import
来源： https://www.cnblogs.com/duanzheng/p/16515618.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。