符合中小企业对网站设计、功能常规化式的企业展示型网站建设
本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...
商城网站建设因基本功能的需求不同费用上面也有很大的差别...
手机微信网站开发、微信官网、微信商城网站...
这期内容当中小编将会给大家带来有关java对hdfs的操作是怎样的,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
员工经过长期磨合与沉淀,具备了协作精神,得以通过团队的力量开发出优质的产品。创新互联坚持“专注、创新、易用”的产品理念,因为“专注所以专业、创新互联网站所以易用所以简单”。公司专注于为企业提供成都网站制作、网站设计、微信公众号开发、电商网站开发,微信小程序开发,软件按需制作网站等一站式互联网企业服务。
package hdfs; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.net.URI; 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; import org.apache.hadoop.io.IOUtils; /** * java对hdfs的操作 * @author 林 * */ public class App2 { public static final String HDFS_PATH = "hdfs://hadoop:9000"; public static final String DRI_PATH = "/d1000"; public static final String FILE_PATH = "/d1000/f1000"; public static void main(String[] args) throws Exception { FileSystem fileSystem = FileSystem.get(new URI(HDFS_PATH),new Configuration()); //创建文件夹 mkDri(fileSystem); //上传文件 uploadDate(fileSystem); //下载文件 downloadFile(fileSystem); //删除文件 deleteFile(fileSystem); } public static void deleteFile(FileSystem fileSystem) throws IOException { fileSystem.delete(new Path(FILE_PATH), true); } //下载文件 public static void downloadFile(FileSystem fileSystem) throws IOException { FSDataInputStream in = fileSystem.open(new Path(FILE_PATH)); FileOutputStream out = new FileOutputStream(new File("D:/copy.txt")); //IOUtils.copyBytes(in, System.out, 2048, true);下载到控制台 IOUtils.copyBytes(in,out, 2048, true); } //上传文件 public static void uploadDate(FileSystem fileSystem) throws IOException, FileNotFoundException { FSDataOutputStream out = fileSystem.create(new Path(FILE_PATH)); FileInputStream in = new FileInputStream("D:/hadoop安装.txt"); IOUtils.copyBytes(in, out, 1024,true); } //创建目录 public static void mkDri(FileSystem fileSystem) throws IOException { fileSystem.mkdirs(new Path(DRI_PATH)); } }
上述就是小编为大家分享的java对hdfs的操作是怎样的了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注创新互联行业资讯频道。