zoukankan      html  css  js  c++  java
  • hbase与sqoop的集成

    1、sqoop抽取mysql表到hbase中

    export HBASE_HOME=/opt/cdh-5.3.6/hbase-0.98.6-cdh5.3.6
    export HADOOP_HOME=/opt/cdh-5.3.6/hadoop-2.5.0-cdh5.3.6
    HADOOP_CLASSPATH=`${HBASE_HOME}/bin/hbase mapredcp`:${HBASE_HOME}/conf bin/sqoop import
    --connect jdbc:mysql://localhost:3306/chavin
    --username root -password mysql
    --table emp
    --columns "empno,ename"
    --hbase-table imp_emp
    --column-family info
    --hbase-row-key empno -m 1


    export HBASE_HOME=/opt/cdh-5.3.6/hbase-0.98.6-cdh5.3.6
    export HADOOP_HOME=/opt/cdh-5.3.6/hadoop-2.5.0-cdh5.3.6
    HADOOP_CLASSPATH=`${HBASE_HOME}/bin/hbase mapredcp`:${HBASE_HOME}/conf bin/sqoop import
    --connect jdbc:mysql://localhost:3306/chavin
    --username root -password mysql
    --table emp
    --columns "empno,ename"
    --hbase-table imp_emp02
    --column-family info
    --hbase-row-key ename -m 1


    export HBASE_HOME=/opt/cdh-5.3.6/hbase-0.98.6-cdh5.3.6
    export HADOOP_HOME=/opt/cdh-5.3.6/hadoop-2.5.0-cdh5.3.6
    HADOOP_CLASSPATH=`${HBASE_HOME}/bin/hbase mapredcp`:${HBASE_HOME}/conf bin/sqoop import
    --connect jdbc:mysql://localhost:3306/chavin
    --username root -password mysql
    --table emp
    --columns "empno,ename"
    --hbase-table imp_emp04 --hbase-create-table
    --column-family info
    --hbase-row-key empno
    --hbase-bulkload
    --compress -m 1

    2、sqoop抽取mysql表到hive中
    export HIVE_HOME=/opt/cdh-5.3.6/hive-0.13.1-cdh5.3.6
    export HADOOP_HOME=/opt/cdh-5.3.6/hadoop-2.5.0-cdh5.3.6
    HADOOP_CLASSPATH=${HIVE_HOME}/conf:${HADOOP_HOME}/conf bin/sqoop import
    --connect jdbc:mysql://localhost:3306/chavin
    --username root -password mysql
    --table emp
    --columns "empno,ename"
    --hive-import --hive-database chavin
    --create-hive-table --hive-table h_emp01
    --hive-partition-key dt
    --hive-partition-value '2017-10-09'
    --compress -m 1

    3、sqoop实现rdbms与hdfs数据交互

    bin/sqoop import
    --connect jdbc:mysql://db01:3306/chavin
    --username root
    --password mysql
    --table emp
    --target-dir /user/hadoop/sqoop/import/emp
    --num-mappers 1
    --as-parquetfile


    bin/sqoop export
    --connect jdbc:mysql://db01:3306/chavin
    --username root
    --password mysql
    --table emp01
    --export-dir /user/hadoop/sqoop/import/emp

  • 相关阅读:
    利用beautifulsoup4解析Kindle笔记
    对流媒体传输关键指标作简单预测
    Linux上使用Windows软件
    Tex家族关系
    数学基础-概率论05(统计推断-分布拟合检验)
    数学基础-概率论04(统计推断-参数假设检验)
    数学基础-概率论03(统计推断-参数估计)
    数学基础-概率论01(离散型分布)
    数学基础-概率论02 (连续型分布)
    Calibre中使用DeDRM插件进行Kindle电子书解锁
  • 原文地址:https://www.cnblogs.com/wcwen1990/p/7643989.html
Copyright © 2011-2022 走看看