java对hdfs的操作是怎样的

80次阅读
没有评论

共计 1873 个字符,预计需要花费 5 分钟才能阅读完成。

这期内容当中丸趣 TV 小编将会给大家带来有关 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));
 }
}

上述就是丸趣 TV 小编为大家分享的 java 对 hdfs 的操作是怎样的了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注丸趣 TV 行业资讯频道。

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-08-25发表,共计1873字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)