java - Sqoop，Java中将HDFS导出到MySQL

Question

我正在尝试从 HDFS 导出到 MySql，但只能找到以下技术:

public static boolean exportHDFSToSQL() throws InstantiationException, IllegalAccessException, ClassNotFoundException {
    try {
         SqoopOptions options = new SqoopOptions();
         options.setConnectString("jdbc:mysql://localhost:3306/dbName");
         options.setUsername("user_name");
         options.setPassword("pwd");
         options.setExportDir("path of file to be exported from hdfs");
         options.setTableName("table_name");
         options.setInputFieldsTerminatedBy(',');
         options.setNumMappers(1);
         new ExportTool().run(options);
    } catch (Exception e) {
        return false;
    }
    return true;
}

我遇到的问题是 ExportTool().run() 方法。我正在使用 Sqoop 1.4.2，此方法显然已被弃用。想知道实现这一目标的新方法吗？或者向我指出一个有帮助的记录来源。

谢谢

Answer 1

Sqoop 目前不公开任何 Java API，因此不支持此类用法。它可能有效，但 future 的版本可能会打破这种行为。

我希望您看到弃用，因为您正在使用 com.cloudera.sqoop.tool 包中的 ExportTool 类，而该功能已移至 org.apache.sqoop.tool 包中，并且原始实例保留在那里以供向后使用兼容性。您可以在 appropriate Sqoop wiki page 上了解有关命名空间迁移的更多信息。 .