bitscn.com
将记录从mysql导出到hdfs中
01connecturl=jdbc:mysql://localhost:3306/user_action0203username=root0405password=1234560607outputpath=/hdfs/recommend/user_action/watch_record0809tablename= watch_record1011columns=id,uid,mid,timestamp121314ifjobcreated =`sqoop job list | grep import_ watch_record`1516#检查import_ watch_record这个job是否已经创建 如果未创建则创建1718if [ $ifjobcreated = ’’ ] then1920sqoop job import_ watch_record /2122 --create --import /2324 --connect $connecturl/2526 --username $username/2728 --password $password/2930 --target-dir $outputpath/3132 --m 1/3334 --table $tablename/3536 –columns $columns/3738 --incremental append/3940 --check-column id/4142 --last-value 04344fi4546 4748sqoop job --exec import_ watch_record
bitscn.com