kudutable.sql

  "longDescription" : "Eggo Homestyle Waffles 10 Count",
  "brandName" : "Eggo",
  "displayImage" : "https://www.kroger.com/product/images/small/left/0003800040260",
  "price" : "2.59",
  "msrp" : "2.59",
  "tpr" : "0",
  "update_dt" : "20200716165641",
  "upc" : "0003800040260",
  "itemDescription" : "Eggo Homestyle Waffles 10 Count",
  "origin_store" : "kroger"
  
    "longDescription" : "Kroger® Fat Free Skim Milk",
  "brandName" : "Kroger",
  "displayImage" : "https://www.kroger.com/product/images/large/front/0001111042315",
  "price" : "2.19",
  "msrp" : "2.19",
  "tpr" : "0",
  "update_dt" : "20200717160806",
  "upc" : "0001111042315",
  "itemDescription" : "Kroger® Fat Free Skim Milk",
  "origin_store" : "kroger"
  
  insert into prices
(upc,originstore,updatedate,itemdescription,price)
values
('0003450015136', 'kroger', '20200720111539', 'Land O Lakes Salted Butter', '4.49')

select upc, originstore, updatedate, brandname, price, itemdescription, displayimage, longdescription, msrp, tpr
from prices
order by updatedate desc

CREATE TABLE itemprice
(
  upc STRING,
  originstore STRING,
  updatedate STRING,
  longdescription STRING,
  itemdescription STRING,
  brandname STRING,
  displayimage STRING, 
  price STRING,
  msrp STRING,
  tpr STRING,
PRIMARY KEY (upc, originstore, updatedate) ) 
PARTITION BY HASH PARTITIONS 4 
STORED AS KUDU TBLPROPERTIES ('kudu.num_tablet_replicas' = '1');


CREATE TABLE prices
(
  upc STRING,
  originstore STRING,
  updatedate STRING,
  longdescription STRING,
  itemdescription STRING,
  brandname STRING,
  displayimage STRING, 
  price STRING,
  msrp STRING,
  tpr STRING,
PRIMARY KEY (upc, originstore, updatedate) ) 
PARTITION BY HASH PARTITIONS 4 
STORED AS KUDU TBLPROPERTIES ('kudu.num_tablet_replicas' = '1');

CREATE TABLE itemprice
(
       item_id INT,
    price FLOAT,
   created_on TIMESTAMP,
    updated_on TIMESTAMP,	
PRIMARY KEY (item_id) ) 
PARTITION BY HASH PARTITIONS 4 
STORED AS KUDU TBLPROPERTIES ('kudu.num_tablet_replicas' = '1');

CREATE TABLE shelfprice 
(
uuid STRING, 
	systemtime STRING,  
	ipaddress STRING, 
	host STRING, 
	endtime STRING, 
	runtime STRING, 
	starttime STRING, 
	cputemp STRING, 
	diskfree STRING, 
	memory DOUBLE, 
  price STRING,
 PRIMARY KEY (uuid) ) 
PARTITION BY HASH PARTITIONS 4 
STORED AS KUDU TBLPROPERTIES ('kudu.num_tablet_replicas' = '1');


select upc, originstore, prices.brandname, prices.price, updatedate,  prices.itemdescription
from prices
order by brandname desc, updatedate desc, itemdescription desc, price desc