使用sgoop把部分数据导入到HDFS的/MysqlToHDFS3目录下，要求使用自定义SQL语句查询要导入的数据，如导入的字段为 id,name,age,查询条件为age>16，要求以id字段进行分片，使用两个mapper任务并发执行，则语句写法正确的是? bin/sgoop import--connect idbc:mysql://192.168.10.10:3306/userdb\ --username root --delete-target-dir --target-dir/MysqlToHDFS3\ OA -split-by id --fields-terminated-by't’ -query 'select id,name,age from student WHERE age > 16'\ -num-mappers2 bin/sgoop import--connect idbc:mysql://192.168.10.10:3306/userdb\ -username root-delete-target-dir-target-dir MysalToHDFS3\ B --query "select id.name.aae from student WHERE age > 16 and $CONDITIONS" -split-by id --fields-terminated-by't’ --num-mappers 2 bin/sgoop import--connect jdbc:mysql://192.168.10.10:3306/userdb\ --username root-delete-target-dir-target-dir MysqlToHDFS3\ OC --sp it-by id --fie ds-terminated-by"t --query "select id,name,age from student WHERE age > 16 and $CONDITIONS" -m 2 bin/sgoop import--connect idbc:mysgl://192.168.10.10:3306/userdb\ --username root-delete-target-dir-target-dir/MysalToHDFS3\ OD -query 'select id,name age from student WHERE age > 16 and $CONDITIONS'\ --split-by id --fields-terminated-by'\t’\ -m 2

正确的语句写法是：bin/sgoop import --connect jdbc:mysql://192.168.10.10:3306/userdb --username root --delete-target-dir --target-dir /MysqlToHDFS3 -split-by id --fields-terminated-by '\t' --query "select id,name,age from student WHERE age > 16 AND \$CONDITIONS" --num-mappers 2。

相关问题

使用sqoop将数据从MySQL导入hdfs的语句

可以使用以下 Sqoop 命令将 MySQL 中的数据导入 HDFS：

sqoop import \
--connect jdbc:mysql://<MySQL服务器IP地址>:<MySQL端口号>/<数据库名> \
--username <用户名> \
--password <密码> \
--table <表名> \
--target-dir <HDFS目标路径> \
--m <mapreduce任务数>

其中，<MySQL服务器IP地址> 是 MySQL 服务器的 IP 地址，<MySQL端口号> 是 MySQL 服务器上开放的端口号，默认为 3306；<数据库名> 是要导入数据的数据库名；<用户名> 和 <密码> 分别是 MySQL 的登录用户名和密码；<表名> 是要导入数据的表名；<HDFS目标路径> 是数据导入 HDFS 后的存储路径，需要以 HDFS URL 形式指定，如 `hdfs://<HDFS服务器IP地址>:<HDFS端口号>/<目录路径>`；<mapreduce任务数> 是指定导入数据时的 MapReduce 任务数。

例如，要将 MySQL 中的 EMP 表导入 HDFS 的 `/user/hadoop/EMP` 目录下，并使用 4 个 MapReduce 任务，可以使用以下命令：

sqoop import \
--connect jdbc:mysql://192.168.1.100:3306/mydb \
--username root \
--password password \
--table EMP \
--target-dir hdfs://192.168.1.101:9000/user/hadoop/EMP \
--m 4

执行该命令后，Sqoop 会将 EMP 表中的数据导入到 HDFS 的 `/user/hadoop/EMP` 目录下。

使用sqoop， 将数据导入到hdfs中

可以使用以下命令将数据从关系型数据库中导入到HDFS中：

sqoop import --connect jdbc:mysql://host/database --username user --password password --table table_name --target-dir /path/to/hdfs/directory --fields-terminated-by ',' --lines-terminated-by '\n'

其中，需要将 `host` 和 `database` 替换为实际的主机名和数据库名，`user` 和 `password` 替换为数据库的用户名和密码，`table_name` 替换为要导入的表名，`/path/to/hdfs/directory` 替换为要将数据导入到的HDFS目录路径，`fields-terminated-by` 和 `lines-terminated-by` 分别指定列之间的分隔符和行之间的分隔符。

注意，需要在执行该命令之前，确保已经安装并配置好了sqoop，并且已经在Hadoop集群中启动了HDFS。