// On Terminal window-
sqoop job \
--create hive_sqoop_job \
-- import \
--connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" \
--username "retail_dba" \
--password "cloudera" \
--table products_replica \
--check-column product_id \
--incremental append \
--last-value 0 \
--hive-import \
--hive-table products_hive \
--hive-database problem5;
// On Hive window:
create database problem5;
use problem5;
create table products_hive (
product_id int,
product_category_id int,
product_name string,
product_description string,
product_price float,
product_imaage string,
product_grade int,
product_sentiment string
);
// On Terminal window
sqoop job --exec hive_sqoop_job
// On MySQL window
insert into products_replica
values (1378,4,'something 1376','something 2',10.00,'not avaialble',null,'NOT APPLICABLE');
insert into products_replica
values (1379,4,'something 1376','something 2',10.00,'not avaialble',null,'NOT APPLICABLE');
// On Terminal Window
sqoop job --exec hive_sqoop_job
// On Hive Window
select * from products_hive;