Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- sqoop list-databases --connect "jdbc:mysql://quickstart.cloudera:3306" --username=retail_dba --password=cloudera
- sqoop list-tables --connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" --username=retail_dba --password=cloudera
- sqoop import-all-tables --connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" --username=retail_dba --password=cloudera --warehouse-dir /lab3
- sqoop import-all-tables -m 12 --connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" --username=retail_dba --password=cloudera --as-avrodatafile --warehouse-dir /lab3
- sqoop import --connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" --username=retail_dba --password=cloudera --table orders --where "order_status='CLOSED'" --target-dir /wherequery
- sqoop import --connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" --username=retail_dba --password=cloudera --table orders --columns order_status --where "order_status='CLOSED'" --target-dir /wherequery1
- sqoop import --connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" --username=retail_dba --password=cloudera --table orders --columns order_status --target-dir /wherequery2
- all_statuses = sc.textFile('/wherequery1').filter(lambda x: len(x)>0).map(lambda x :(x,1)).reduceByKey(lambda x,y:x+y).sortByKey(True)
Add Comment
Please, Sign In to add comment
