चूंकि स्कूप विकल्प विधि बहिष्कृत है, आप निम्न कोड का उपयोग कर सकते हैं:
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
, username
, password
MySQL के लिए। कृपया अपना पोर्ट core-site.xml
. से जांचें (मेरे मामले में यह 54310 है)