CREATE TABLE products(product_name VARCHAR, cost DOUBLE) WITH (kafka_topic='products', partitions=10, value_format='json');
insert into products(rowkey, product_name, cost) values('1', 'Orange Juice', 2.50);
insert into products(rowkey, product_name, cost) values('2', 'Bluebery Juice', 4.50);
insert into products(rowkey, product_name, cost) values('3', 'Apple Juice', 1.50);

CREATE STREAM orders(ProductRowKey VARCHAR, Qtty int) WITH (kafka_topic='orders', partitions=10, value_format='json');
insert into orders(rowkey, productrowkey, Qtty) values('1', '1', 1);
insert into orders(rowkey, productrowkey, Qtty) values('2', '1', 1);
insert into orders(rowkey, productrowkey, Qtty) values('3', '1', 3);
insert into orders(rowkey, productrowkey, Qtty) values('4', '2', 3);
insert into orders(rowkey, productrowkey, Qtty) values('5', '2', 1);
insert into orders(rowkey, productrowkey, Qtty) values('6', '3', 1);