2016-01-20 139 views

回答

0

这可以通过shell脚本完成。

1)准备一个输入文件,其中包含DBNAME列表.TABLENAME 2)shell脚本将该文件作为输入,逐行迭代并为每行执行sqoop语句。

while read line; 
do 

    DBNAME=`echo $line | cut -d'.' -f1` 
    tableName=`echo $line | cut -d'.' -f2` 


    sqoop import -Dmapreduce.job.queuename=$RM_QUEUE_NAME --connect '$JDBC_URL;databaseName=$DBNAME;username=$USERNAME;password=$PASSWORD' --table $tableName --target-dir $DATA_COLLECTOR/$tableName --fields-terminated-by '\001' -m 1 

done<inputFile 
相关问题