java向hdfs提交命令_Java语言操作HDFS常用命令测试代码
本文主要向大家介绍了Java语言操作HDFS常用命令测试代码,通过具体的内容向大家展示,希望对大家学习JAVA语言有所帮助。
package com.yxc.hdfs;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.*;
import org.apache.hadoop.io.IOUtils;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Date;
/**
* 测试HDFS的API
*
* @author yxc
* @create 2018-05-03 18:21
**/
public class TestHDFS04 {
private Configuration cf = null;
private FileSystem fs = null;
/**
* 获取配置信息,以及获取文件系统
*/
@Before
public void beforeRun() throws URISyntaxException, IOException, InterruptedException {
//获取配置信息
cf = new Configuration();
//获取文件系统
fs = FileSystem.get(new URI("hdfs://hadoop102:9000"), cf, "yxc");
}
/**
* 创建文件目录
*/
@Test
public void mkdir () throws IOException {
boolean mkdirs = fs.mkdirs(new Path("/input/"));
if (mkdirs) {
System.out.println("文件创建成功");
} else {
System.out.println("文件创建失败");
}
}
/**
* 判断目录是否存在
*/
@Test
public void isDirectory() throws IOException {
boolean directory = fs.isDirectory(new Path("/input/"));
if (directory) {
System.out.println("存在input 的这个目录");
} else {
System.out.println("不存在input的这个目录");
}
}
/**
* 删除文件或文件目录
*/
@Test
public void delete() throws IOException {
boolean delete = fs.delete(new Path("/input/"), true);
if (delete) {
System.out.println("成功删除");
} else {
System.out.println("删除失败");
}
}
/**
* 获取文件下的资源
*/
@Test
public void getFile() throws IOException {
RemoteIterator listFiles = fs.listFiles(new Path("/"), true);
if (listFiles == null) {
System.out.println("文件下没有资源");
} else {
System.out.println("文件下有资源");
}
while (listFiles.hasNext()) {
LocatedFileStatus file = listFiles.next();
if (file.isDirectory()) {
System.out.println("是文件夹");
} else {
System.out.println("是文件");
}
System.out.println("文件名:"+file.getPath().getName());
}
}
/**
* 上传文件
*/
@Test
public void upFile() throws IOException {
//配置信息
//获取文件系统
//获取输入流
FileInputStream inputStream = new FileInputStream(new File("D:/yue5.txt"));
//获取输出流
FSDataOutputStream outputStream = fs.create(new Path(
本文由职坐标整理并发布,希望对同学们有所帮助。了解更多详情请关注编程语言JAVA频道!
java向hdfs提交命令_Java语言操作HDFS常用命令测试代码相关推荐
- Java中使用Jedis连接Redis对Hash进行操作的常用命令
场景 Centos中Redis的下载编译与安装(超详细): https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103967334 Re ...
- Java中使用Jedis连接Redis对Set进行操作的常用命令
场景 Centos中Redis的下载编译与安装(超详细): https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103967334 Re ...
- Java中使用Jedis连接Redis对List进行操作的常用命令
场景 Centos中Redis的下载编译与安装(超详细): https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103967334 Re ...
- Java中使用Jedis连接Redis对String进行操作的常用命令
场景 Centos中Redis的下载编译与安装(超详细): https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103967334 Re ...
- git菜单形式的_Idea:Git的常用菜单操作和常用命令
工作中多人使用版本控制软件协作开发,常见的应用场景归纳如下: 假设小组中有两个人,组长小张,组员小袁 场景一:小张创建项目并提交到远程Git仓库 场景二:小袁从远程Git仓库上获取项目源码 场景三:小 ...
- linux常用命令_干货:Linux常用命令全称及讲解
从事IT行业的很多人都会使用Linux常用命令,但是知道这些常用命令全称的人并不多,让我们来看看这些常用命令对应的全称吧!小编精心整理了一下,毕竟常用命令比较多,如果没有你常用的还望海涵,可以评论区补 ...
- Java中使用Jedis连接Redis对Key进行操作的常用命令
场景 Java中使用Jedis连接池连接Redis数据库流程: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/104914320 ...
- java jstat 命令_java高分局之jstat命令使用(转)
转自:http://blog.csdn.net/h_025/article/details/52813817 java高分局之jstat命令使用 jstat命令可以查看堆内存各部分的使用量,以及加载类 ...
- hdfs user 连接_Python入门操作HDFS
点击上方蓝色字体,关注我们 读完需 7 分钟 速读需 3 分钟 在了解了Hadoop的基本使用后,需要通过编程语言进一步操作.对于没有Java基础的运维人,Python如何操作hdfs也就成了我们优先 ...
最新文章
- 读书笔记-《增长黑客》-搭建增长团队
- 检查值是否是JavaScript中的对象
- 学习一段深有感悟的讲话
- Hibernate悲观锁/乐观锁
- 蓝桥杯2015初赛-三羊献瑞-枚举
- jQuery使用(八):运动方法
- 无线多串口服务器,多串口通信服务器
- python 读取excel图片_如何用Python读取Excel中图片?
- C# 曲线上的点(一) 获取指定横坐标对应的纵坐标值
- python——keyword模块
- Linux系统清空回收站
- Python制作Gif图片
- mac上使用nginx代理
- Cell Stem Cell | 动物所刘光慧等显示年轻血液可逆转衰老进程
- latex中lstlisting使用
- 南大计算机学院有几个院士,中国大学两院院士数量排名,看看谁的科研实力最强...
- Gta4 微软服务器,R星发布《GTA4》Win10补丁 业界良心从不令人失望
- 用递归方法将十进制转化为二进制数
- 程序员小灰漫画算法合集
- css和js带参数v或version