Sqoop的安装和配置以及Sqoop的基本操作

一、概述

Sqoop是apache旗下一款**“Hadoop和关系数据库服务器之间传送数据”**的工具。

导入数据:把MySQL,Oracle数据导入到Hadoop的HDFS、HIVE、HBASE等数据存储系统;

**导出数据:**从Hadoop的文件系统中导出数据到关系数据库mysql等

sqoop1sqoop2架构对比

sqoop1架构:

sqoop2架构:

、****Sqoop工作机制

将导入或导出命令翻译成mapreduce程序来实现

在翻译出的mapreduce中主要是对inputformat和outputformat进行定制

Sqoop的安装配置

安装sqoop的前提是已经具备java和hadoop的环境

1、下载并解压

下载地址

http://archive.cloudera.com/cdh5/cdh/5/

      sqoop1版本详细下载地址

http://archive.cloudera.com/cdh5/cdh/5/sqoop-1.4.6-cdh5.14.0.tar.gz

    sqoop2版本详细下载地址

http://archive.cloudera.com/cdh5/cdh/5/sqoop2-1.99.5-cdh5.14.0.tar.gz

我们这里使用sqoop1的版本,下载之后上传到/export/softwares目录下,然后进行解压

1  #cd /export/softwares 2  #tar -zxvf sqoop-1.4.6-cdh5.14.0.tar.gz -C ../servers/

  

2、修改配置文件

1  #cd /export/servers/sqoop-1.4.6-cdh5.14.0/conf/ 2  #cp sqoop-env-template.sh sqoop-env.sh

  

1  #vim sqoop-env.sh 2  export HADOOP_COMMON_HOME=/export/servers/hadoop-2.6.0-cdh5.14.0 3  export HADOOP_MAPRED_HOME=/export/servers/hadoop-2.6.0-cdh5.14.0 4  export HIVE_HOME=/export/servers/hive-1.1.0-cdh5.14.0

  

3、加入额外****的依赖包

  sqoop的使用需要添加三个额外的依赖包,mysql的驱动包,oracle的驱动包,java-json依赖包,不然就会报错

   mysql-connector-java-5.1.40.jar

   ojdbc8.jar

   java-json.jar

  

4、验证启动

1# cd /export/servers/sqoop-1.4.6-cdh5.14.0 2# bin/sqoop-version

  

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

皕杰报表之UUID

​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

2020年前端实用代码段,为你的工作保驾护航

有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )

Python3:sqlalchemy对mysql数据库操作,非sql语句

Python3:sqlalchemy对mysql数据库操作,非sql语句python3authorlizmdatetime2018020110:00:00coding:utf8'''