如何将mysql表转移到hive?

How to transfer mysql table to hive?(如何将mysql表转移到hive?)
本文介绍了如何将mysql表转移到hive?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我有一个很大的 mysql 表,我想将它转移到一个 Hadoop/Hive 表.是否有标准命令或技术可以将简单(但很大)的表从 Mysql 传输到 Hive?该表主要存储分析数据.

I have a large mysql table that I would like to transfer to a Hadoop/Hive table. Are there standard commands or techniques to transfer a simple (but large) table from Mysql to Hive? The table stores mostly analytics data.

推荐答案

  1. 首先下载mysql-connector-java-5.0.8,把jar包放到Sqoop的lib和bin文件夹

  1. First of all download mysql-connector-java-5.0.8 and put the jar to lib and bin folder of Sqoop

在 Hive 中创建表定义,使用 确切的字段名称和类型,就像在 mysql 中一样

Create the table definition in Hive with exact field names and types as in mysql

sqoop import --verbose --fields-terminated-by ',' --connect jdbc:mysql://localhost/test --table employee --hive-import --warehouse-dir/user/hive/warehouse--fields-terminated-by ',' --split-by id --hive-table 员工

sqoop import --verbose --fields-terminated-by ',' --connect jdbc:mysql://localhost/test --table employee --hive-import --warehouse-dir /user/hive/warehouse --fields-terminated-by ',' --split-by id --hive-table employee

测试 - 数据库名称

employee - 表名(存在于测试中)

employee - Table name (present in test)

/user/hive/warehouse - HDFS 中需要导入数据的目录

/user/hive/warehouse - Directory in HDFS where the data has to be imported

--split-by id - id可以是'employee'表的主键

--split-by id - id can be the primary key of the table 'employee'

--hive-table employee - 其定义存在于 Hive 中的雇员表

--hive-table employee - employee table whose definition is present in Hive

Sqoop 用户指南(学习 Sqoop 的最佳指南之一)

Sqoop User Guide (One of the best guide for learning Sqoop)

这篇关于如何将mysql表转移到hive?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!

相关文档推荐

Hibernate reactive No Vert.x context active in aws rds(AWS RDS中的休眠反应性非Vert.x上下文处于活动状态)
Bulk insert with mysql2 and NodeJs throws 500(使用mysql2和NodeJS的大容量插入抛出500)
Flask + PyMySQL giving error no attribute #39;settimeout#39;(FlASK+PyMySQL给出错误,没有属性#39;setTimeout#39;)
auto_increment column for a group of rows?(一组行的AUTO_INCREMENT列?)
Sort by ID DESC(按ID代码排序)
SQL/MySQL: split a quantity value into multiple rows by date(SQL/MySQL:按日期将数量值拆分为多行)