hadoop - 通过JAVA API进行Sqoop

Question

我们正在尝试将数据从mysql压缩到HDFS。当我们运行代码时，数据将存储在本地文件系统中。我们希望数据在HDFS中。有人可以用以下代码建议我们吗？

    SqoopOptions options = new SqoopOptions();
    options.setConnectString("jdbc:mysql:hostname/db_name");
    options.setUsername("user");
    options.setPassword("pass");
    options.setTableName("table");
    options.setDirectMode(true);
    options.setNumMappers(4);  
    options.setDriverClassName("com.mysql.jdbc.Driver");
    options.setSqlQuery("select * from table");
    options.setWhereClause("value > 15.0");
    options.setTargetDir("output");
    options.doHiveImport();
    System.out.println();
    int ret=new ImportTool().run(options);
    System.out.println(ret);

Answer 1

我在hdfs中运行了相同的程序，并得到了输出:)