网站链接: element-ui dtcms
当前位置: 首页 > 技术博文  > 技术博文

学习笔记

2021/5/10 15:56:24 人评论

Hadoop JAVA端错误案例import com.google.inject.internal.cglib.core.$ClassInfo;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.FileSystem;import org.apache.hadoop.fs.Path;import org.junit.Before;import org.junit.Test;import java.io.IO…

Hadoop JAVA端错误案例


import com.google.inject.internal.cglib.core.$ClassInfo;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

public class HdfsFS_Demo_02 {
FileSystem fs=null;
@Before
public void init() throws Exception {
//1、配置信息对象 用户自定义设置 比如设置副本个数 切块大小
Configuration conf = new Configuration();
//2、获取hdfs客户端对象
/*
* 参数一 URI
* 参数二 配置对象
* 参数三 用户
* */
fs = FileSystem.newInstance(new URI(“hdfs://linux01:8020”),conf,“root”);
// 错误案例
// FileSystem fs = FileSystem.newInstance(new URI(“hdfs://linux01:8020”),conf,“root”);
}
@Test
public void testMkdir() throws Exception {
// 上传文件到hdfs
fs.mkdirs(new Path("/sdfsdf/sdf"));
fs.close();
}

@Test
public void testMV() throws Exception {
    //  改名  移动
    fs.rename(new Path("/img"),new Path("/sdfsdf/"));
    fs.close();
}

}

相关资讯

    暂无相关的数据...

共有条评论 网友评论

验证码: 看不清楚?