| --! 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); |