Làm cách nào để nhập bảng từ MySQL sang Hive bằng Java?

Vì phương pháp tùy chọn sqoop không được dùng nữa, bạn có thể sử dụng mã sau:

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);
}

Vui lòng sử dụng đường dẫn path thích hợp , username , password cho mysql. Vui lòng kiểm tra cổng của bạn từ core-site.xml (trong trường hợp của tôi là 54310)