Mysql
 sql >> डेटाबेस >  >> RDS >> Mysql

जावा का उपयोग करके MySQL से Hive में तालिका कैसे आयात करें?

चूंकि स्कूप विकल्प विधि बहिष्कृत है, आप निम्न कोड का उपयोग कर सकते हैं:

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 है)




  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. क्या php/mysql के लिए sql इंजेक्शन की पहचान करने के लिए कोई स्थिर विश्लेषण उपकरण है?

  2. NHibernate सम्मिलित करेगा लेकिन mysql चलाने वाले साझा सर्वर के साथ होस्ट करने के लिए स्थानांतरित होने के बाद अपडेट नहीं होगा

  3. Group_concat के लिए शून्य मान वाली पंक्तियाँ वापस नहीं आई

  4. ORDER BY क्लॉज में बाध्यकारी पैरामीटर परिणाम का आदेश क्यों नहीं देता है?

  5. MySQL क्वेरी में टेबल नाम के आसपास बैकटिक का महत्व