Mysql
 sql >> Datenbank >  >> RDS >> Mysql

Wie übertrage ich eine MySQL-Tabelle in Hive?

  1. Laden Sie zuerst mysql-connector-java-5.0.8 herunter und legen Sie die JAR-Datei in den lib- und bin-Ordner von Sqoop

  2. Erstellen Sie die Tabellendefinition in Hive mit genauen Feldnamen und -typen wie 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 employee

test - Datenbankname

employee - Tabellenname (im Test vorhanden)

/user/hive/warehouse - Verzeichnis in HDFS, in das die Daten importiert werden müssen

--split-by id - id kann der Primärschlüssel der Tabelle 'employee' sein

--hive-table employee - Mitarbeitertabelle, deren Definition in Hive vorhanden ist

Sqoop-Benutzerhandbuch (Eine der besten Anleitungen zum Erlernen von Sqoop)