大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。
Jetbrains全系列IDE稳定放心使用
public class HdfsClient1 {
private FileSystem fs;
//初始化一个FileSystem
@Before
public void init() throws URISyntaxException, IOException, InterruptedException {
//1:获取文件系统
URI uri = new URI("hdfs://myhadoop105:9820");
Configuration conf = new Configuration();
conf.set("dfs.replication","6");
String user = "atguigu";
fs = FileSystem.get(uri, conf, user);
}
@After
public void closeResources() throws IOException {
//3:关闭资源
fs.close();
}
@Test
public void testMkdir() throws IOException {
fs.mkdirs(new Path("/hdfs/windowsOperator/operator01"));
}
@Test
public void testPut() throws IOException {
fs.copyFromLocalFile(false , false , new Path("G:/code/test/day08课堂记录.txt") , new Path("/hdfs/windowsOperator/operator01"));
}
@Test
public void testGet() throws IOException {
fs.copyToLocalFile(new Path("/hdfs/windowsOperator/operator01"),new Path("G:\\code\\test\\test"));
}
@Test
public void testMove() throws IOException {
fs.rename(new Path("/hdfs/windowsOperator/day08课堂记录.txt"),new Path("/hdfs/windowsOperator/day08"));
}
@Test
public void testDelete() throws IOException {
fs.delete(new Path("/hdfs/windowsOperator/operator01"),true);
}
@Test
public void testIsFile() throws IOException {
FileStatus[] fileStatuses = fs.listStatus(new Path("/"));
for (FileStatus fileStatus : fileStatuses) {
//判断是否是文件
if (fileStatus.isFile()){
System.out.println("-:"+fileStatus.getPath().getName());
}else {
System.out.println("d:" + fileStatus.getPath().getName());
}
}
}
@Test
public void testListFiles() throws IOException {
// f:要查看的目录路径
// r:是否递归查看
RemoteIterator<LocatedFileStatus> listFiles = fs.listFiles(new Path("/"), true);
while (listFiles.hasNext()){
LocatedFileStatus fileStatus = listFiles.next();
System.out.println("-------------------------" + fileStatus.getPath() + "--------------------");
System.out.println(fileStatus.getPermission());
System.out.println(fileStatus.getOwner());
System.out.println(fileStatus.getGroup());
System.out.println(fileStatus.getLen());
System.out.println(fileStatus.getModificationTime());
System.out.println(fileStatus.getReplication());
System.out.println(fileStatus.getBlockLocations());
System.out.println(fileStatus.getPath().getName());
//快信息
BlockLocation[] blockLocations = fileStatus.getBlockLocations();
System.out.println(Arrays.toString(blockLocations));
}
}
}
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/186043.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...