使用分隔符和转义字符从 JAVA API 导入 Sqoop答案

【问题标题】：Sqoop import from JAVA API using delimiters and escape chars使用分隔符和转义字符从 JAVA API 导入 Sqoop
【发布时间】：2014-05-09 15:48:49
【问题描述】：

我正在尝试将数据从 RDBMS(Mysql) 导入 HDFS。我在 Sqoop 教程上做了一些阅读，发现一些有用的链接。 http://devslogics.blogspot.com/2013/09/sqoop-java-client.html?showComment=1399588094791#c7484088811270691337 我可以使用上面粘贴的链接中的代码将数据导入 TEXT_FILE 中的 HDFS。 Sqoop 默认使用逗号作为默认分隔符。这对我不起作用。我现在想要实现的是自定义分隔符/转义字符。

我也可以通过 shell 执行以下命令来做到这一点 sqoop import --connect jdbc:mysql://xxx.xx.xx:3306/sqoop --username xxx --password xxx --table students --enclosed-by \" --escaped-by \"

非常感谢任何有关如何通过 sqoop-client java api 实现此功能的帮助。

提前致谢肖恩

【问题讨论】：

标签： java sqoop sqoop2

【解决方案1】：

从您链接的博客文章中可以看出您正在使用 Sqoop2。

很遗憾，Sqoop2 还不允许您设置分隔符。

当你运行命令行“sqoop”时，你运行的是Sqoop1，此时它支持更多选项。

您可以按照此处的最佳答案在您的 java 代码中使用 Sqoop1： How to use Sqoop in Java Program?

【讨论】：

谢谢格温。我会尝试使用 SEQUENCE_FILE 格式。