首先:什么是jUnit 回顾: https://www.cnblogs.com/Liuyt-61/p/10374732.html
上一节我们知道:
/**
* 使用Java API操作HDFS文件系统
* 关键点:
* 1)创建 Configuration
* 2)获取 FileSystem
* 3)...剩下的就是HDFS API的操作了
*/
回顾:https://www.cnblogs.com/Liuyt-61/p/10737466.html
先上代码:
public class HDFSApp { public static final String HDFS_PATH = "hdfs://hadoop000:8020";
FileSystem fileSystem = null;
Configuration configuration = null; @Before
public void setUp() throws Exception{
System.out.println("setUp-----------");
configuration = new Configuration();
/*
* 构造一个访问制定HDFS系统的客户端对象
* 第一个参数:HDFS的URI
* 第二个参数:客户端制定的配置参数
* 第三个参数:客户端的身份,说白了就是用户名
*/
fileSystem = FileSystem.get(new URI(HDFS_PATH),configuration,"hadoop");
} /*
* 创建HDFS文件夹
*/
@Test
public void testMkdir() throws Exception{
fileSystem.mkdirs(new Path("/hdfsapi/test"));
} @After
public void tearDown(){
configuration = null;
fileSystem = null;
System.out.println("----------tearDown------");
} }
继续回顾,我们要使用Java API操作操作HDFS,需要①创建 Configuration ②获取 FileSystem,这俩操作按照逻辑理应放在了jUnit的@Before下,然后就在@Test下进行mkdir操作,最后再在@After下进行Configuration和FileSystem的置空操作即可。运行testMkdir测试即可。所有操作过程像上一回说的一样哪里不会Ctrl点哪里!
此时我们可以通过终端控制台进行查看文件夹是否创建成功:
当然也可以通过浏览器查看是否创建成功:输入 地址IP:50070 回车, 例如 192.168.42.110:50070 回车,
进去点击Utilities下拉列表的Browse the fiel system,点Go!就能看到:
点进去hdfsapi:
操作成功。