Advertisement
Guest User

Untitled

a guest
Jun 19th, 2017
71
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.08 KB | None | 0 0
  1. // On Terminal window-
  2.  
  3. sqoop job \
  4. --create hive_sqoop_job \
  5. -- import \
  6. --connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" \
  7. --username "retail_dba" \
  8. --password "cloudera" \
  9. --table products_replica \
  10. --check-column product_id \
  11. --incremental append \
  12. --last-value 0 \
  13. --hive-import \
  14. --hive-table products_hive \
  15. --hive-database problem5;
  16.  
  17. // On Hive window:
  18.  
  19. create database problem5;
  20.  
  21. use problem5;
  22. create table products_hive (
  23. product_id int,
  24. product_category_id int,
  25. product_name string,
  26. product_description string,
  27. product_price float,
  28. product_imaage string,
  29. product_grade int,
  30. product_sentiment string
  31. );
  32.  
  33. // On Terminal window
  34.  
  35. sqoop job --exec hive_sqoop_job
  36.  
  37. // On MySQL window
  38.  
  39. insert into products_replica
  40. values (1378,4,'something 1376','something 2',10.00,'not avaialble',null,'NOT APPLICABLE');
  41. insert into products_replica
  42. values (1379,4,'something 1376','something 2',10.00,'not avaialble',null,'NOT APPLICABLE');
  43.  
  44. // On Terminal Window
  45.  
  46. sqoop job --exec hive_sqoop_job
  47.  
  48. // On Hive Window
  49.  
  50. select * from products_hive;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement