大数据培训HDFS客户端环境准备

1．根据自己电脑的操作系统拷贝对应的编译后的hadoop jar包到非中文路径（例如：D:\Develop\hadoop-2.7.2），如图3-4所示。

图3-4  编译后的hadoop jar包

2．配置HADOOP_HOME环境变量，如图3-5所示。

图3-5  配置HADOOP_HOME环境变量

3. 配置Path环境变量，如图3-6所示。

图3-6  配置Path环境变量

4．创建一个Maven工

程HdfsClientDemo

5．导入相应的依赖坐标+日志添加

<dependencies>

      <dependency>

          <groupId>junit</groupId>

          <artifactId>junit</artifactId>

          <version>RELEASE</version>

      </dependency>

      <dependency>

          <groupId>org.apache.logging.log4j</groupId>

          <artifactId>log4j-core</artifactId>

          <version>2.8.2</version>

      </dependency>

      <dependency>

          <groupId>org.apache.hadoop</groupId>

          <artifactId>hadoop-common</artifactId>

          <version>2.7.2</version>

      </dependency>

      <dependency>

          <groupId>org.apache.hadoop</groupId>

          <artifactId>hadoop-client</artifactId>

          <version>2.7.2</version>

      </dependency>

      <dependency>

          <groupId>org.apache.hadoop</groupId>

          <artifactId>hadoop-hdfs</artifactId>

          <version>2.7.2</version>

      </dependency>

      <dependency>

          <groupId>jdk.tools</groupId>

          <artifactId>jdk.tools</artifactId>

          <version>1.8</version>

          <scope>system</scope>

          <systemPath>${JAVA_HOME}/lib/tools.jar</systemPath>

      </dependency>

</dependencies>

注意：如果Eclipse/Idea打印不出日志，在控制台上只显示

1.log4j:WARN No appenders could be found for logger (org.apache.hadoop.util.Shell).  

2.log4j:WARN Please initialize the log4j system properly.  

3.log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.

需要在项目的src/main/resources目录下，新建一个文件，命名为“log4j.properties”，在文件中填入

log4j.rootLogger=INFO, stdout

log4j.appender.stdout=org.apache.log4j.ConsoleAppender

log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] – %m%n

log4j.appender.logfile=org.apache.log4j.FileAppender

log4j.appender.logfile.File=target/spring.log

log4j.appender.logfile.layout=org.apache.log4j.PatternLayout

log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] – %m%n

6．创建包名：com.atguigu.hdfs

7．创建HdfsClient类

public class HdfsClient{  

@Test

public void testMkdirs() throws IOException, InterruptedException, URISyntaxException{

 

      // 1 获取文件系统

      Configuration configuration = new Configuration();

      // 配置在集群上运行

      // configuration.set(“fs.defaultFS”, “hdfs://hadoop102:9000”);

      // FileSystem fs = FileSystem.get(configuration);

 

      FileSystem fs = FileSystem.get(new URI(“hdfs://hadoop102:9000”), configuration, “atguigu”);

 

      // 2 创建目录

      fs.mkdirs(new Path(“/1108/daxian/banzhang”));

 

      // 3 关闭资源

      fs.close();

   }

}

8．执行程序

运行时需要配置用户名称，如图3-7所示

图3-7  配置用户名称

客户端去操作HDFS时，是有一个用户身份的。默认情况下，HDFS客户端API会从JVM中获取一个参数来作为自己的用户身份：-DHADOOP_USER_NAME=atguigu，atguigu为用户名称。

想要了解跟多关于大数据培训课程内容欢迎关注尚硅谷大数据培训，尚硅谷除了这些技术文章外还有免费的高质量大数据培训课程视频供广大学员下载学习

上一篇: 怎么判断前端培训老师的水平
下一篇: 前端培训Vue条件渲染