sql >> データベース >  >> RDS >> Mysql

Javaを使用してMySQLからHiveにテーブルをインポートする方法は?

    sqoop optionsメソッドは非推奨になっているため、次のコードを使用できます。

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

    適切なHadoopおよびハイブウェアハウスのpathを使用してください 、usernamepassword mysqlの場合。 core-site.xmlからポートを確認してください (私の場合は54310です)




    1. アップロードする前に、選択したファイルをHTML入力で表示します

    2. jQueryAjaxを介してPHP配列を渡す

    3. SQL Serverの区切り文字なしでdatetime文字列をdatetimeとして変換する方法は?

    4. SQLServer浮動小数点データ型の計算と10進数