Java - MySQL sang Hive Nhập trong đó MySQL đang chạy trên Windows và Hive đang chạy trên Cent OS (Horton Sandbox)

Có, bạn có thể làm điều đó thông qua ssh. Horton Sandbox được cài đặt sẵn hỗ trợ ssh. Bạn có thể thực hiện lệnh sqoop thông qua ssh client trên windows. Hoặc nếu bạn muốn làm theo chương trình (đó là những gì tôi đã làm trong java), bạn phải làm theo bước này.

1. Tải xuống thư viện java sshxcute: https://code.google.com/p/sshxcute/
2. Thêm vào đường dẫn xây dựng của dự án java của bạn có chứa mã java sau đây

import net.neoremind.sshxcute.core.SSHExec;
import net.neoremind.sshxcute.core.ConnBean;
import net.neoremind.sshxcute.task.CustomTask;
import net.neoremind.sshxcute.task.impl.ExecCommand;

public class TestSSH {

public static void main(String args[]) throws Exception{

    // Initialize a ConnBean object, parameter list is ip, username, password

    ConnBean cb = new ConnBean("192.168.56.102", "root","hadoop");

    // Put the ConnBean instance as parameter for SSHExec static method getInstance(ConnBean) to retrieve a singleton SSHExec instance
    SSHExec ssh = SSHExec.getInstance(cb);          
    // Connect to server
    ssh.connect();
    CustomTask sampleTask1 = new ExecCommand("echo $SSH_CLIENT"); // Print Your Client IP By which you connected to ssh server on Horton Sandbox
    System.out.println(ssh.exec(sampleTask1));
    CustomTask sampleTask2 = new ExecCommand("sqoop import --connect jdbc:mysql://192.168.56.101:3316/mysql_db_name --username=mysql_user --password=mysql_pwd --table mysql_table_name --hive-import -m 1 -- --schema default");
    ssh.exec(sampleTask2);
    ssh.disconnect();   
}
}