@@ -60,4 +60,34 @@ where r < 5
60
60
into path='/tmp/NoopWithWindowing'
61
61
serde 'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
62
62
with serdeproperties('field.delim'=',')
63
- format 'org.apache.hadoop.mapred.TextOutputFormat';
63
+ format 'org.apache.hadoop.mapred.TextOutputFormat';
64
+
65
+ /*
66
+ * NPath1
67
+ */
68
+ select origin_city_name, fl_num, year, month, day_of_month, sz, tpath
69
+ from npath(
70
+ flights_tiny
71
+ partition by fl_num
72
+ order by year, month, day_of_month,
73
+ 'LATE.LATE+',
74
+ 'LATE', arr_delay > 15
75
+ 'origin_city_name, fl_num, year, month, day_of_month, size(tpath) as sz, tpath as tpath'
76
+ )
77
+ into path='/tmp/testNPath';
78
+
79
+ /*
80
+ * NPath2
81
+ */
82
+ select origin_city_name, fl_num, year, month, day_of_month, sz, tpath
83
+ from npath(
84
+ flights_tiny
85
+ partition by fl_num
86
+ order by year, month, day_of_month,
87
+ 'ONTIME.LATE+',
88
+ 'LATE', arr_delay > 15,
89
+ 'EARLY', arr_delay < 0,
90
+ 'ONTIME', arr_delay >=0 and arr_delay <= 15,
91
+ 'origin_city_name, fl_num, year, month, day_of_month, size(tpath) as sz, tpath as tpath'
92
+ )
93
+ into path='/tmp/testNPath';
0 commit comments