blob: 84a03dd96cce30c0b8cd3e2e644bee91ce6a4c27 [file] [log] [blame]
--! qt:dataset:part
set hive.vectorized.execution.enabled=false;
DROP TABLE part_seq;
CREATE TABLE part_seq(
p_partkey INT,
p_name STRING,
p_mfgr STRING,
p_brand STRING,
p_type STRING,
p_size INT,
p_container STRING,
p_retailprice DOUBLE,
p_comment STRING
) STORED AS SEQUENCEFILE ;
LOAD DATA LOCAL INPATH '../../data/files/part.seq' overwrite into table part_seq;
-- SORT_QUERY_RESULTS
-- testWindowingPTFWithPartSeqFile
select p_mfgr, p_name, p_size,
rank() over (partition by p_mfgr order by p_name) as r,
dense_rank() over (partition by p_mfgr order by p_name) as dr,
sum(p_retailprice) over (partition by p_mfgr order by p_name rows between unbounded preceding and current row) as s1
from noop(on part_seq
partition by p_mfgr
order by p_name);