Mysql
 sql >> база данни >  >> RDS >> Mysql

Как да импортирам таблица от MySQL в Hive с помощта на Java?

Тъй като методът на опциите на sqoop е отхвърлен, можете да използвате следния код:

public static void importToHive() throws Exception{

    Configuration config = new Configuration(); 
    config.addResource(new Path("/usr/local/hadoop/conf/core-site.xml"));
    config.addResource(new Path("/usr/local/hadoop/conf/hdfs-site.xml"));
    String[] cmd ={"import", "--connect",<connectionString>,"--username", userName,
     "--password", password,"--hadoop-home", "/usr/local/hadoop","--table",<tableName>,   "--hive-import","--create-hive-table", "--hive-table",<tableName>,"-target-dir",
           "hdfs://localhost:54310/user/hive/warehouse","-m", "1","--delete-target-dir"};

    Sqoop.runTool(cmd,config);
}

Моля, използвайте правилния path на hadoop и склад на кошер , username , password за mysql. Моля, проверете вашия порт от core-site.xml (в моя случай е 54310)




  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Mysql не може да изпълнява повече от 1 заявка наведнъж

  2. В SQL / MySQL каква е разликата между ON и WHERE в изявление за присъединяване?

  3. PDO, $_GET и ИЗБОР от MySQL база данни

  4. Mysql разделяне на низ

  5. Изберете Заявка с OR и NAND