Skip to content

Commit e7af902

Browse files
committed
NPath testing
1 parent c5a3382 commit e7af902

File tree

2 files changed

+33
-27
lines changed

2 files changed

+33
-27
lines changed

windowing/src/test/java/com/sap/hadoop/windowing/runtime2/MRExecutorTest.java

Lines changed: 0 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -76,31 +76,4 @@ public void testSumDelta() throws WindowingException
7676
Assert.assertEquals(r, e);
7777
}
7878

79-
@Test
80-
public void testNPath() throws WindowingException
81-
{
82-
wshell.execute(
83-
" select origin_city_name, fl_num, year, month, day_of_month, sz, tpath " +
84-
" from npath( " +
85-
" flights_tiny " +
86-
" partition by fl_num " +
87-
" order by year, month, day_of_month, " +
88-
" 'LATE.LATE+', " +
89-
" 'LATE', arr_delay > 15, " +
90-
" 'origin_city_name, fl_num, year, month, day_of_month, size(tpath) as sz, tpath as tpath' " +
91-
" ) " +
92-
" into path='/tmp/testNPath' \n" +
93-
" serde 'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe' \n" +
94-
" with serdeproperties('field.delim'=',') \n" +
95-
" format 'org.apache.hadoop.mapred.TextOutputFormat'",
96-
outPrinter);
97-
String r = outStream.toString();
98-
r = r.replace("\r\n", "\n");
99-
System.out.println(r);
100-
String e = "";
101-
//Assert.assertEquals(r, e);
102-
103-
}
104-
105-
10679
}

windowing/src/test/java/com/sap/hadoop/windowing/runtime2/WindowingTestsFactory.java

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -387,6 +387,39 @@ public class WindowingTestsFactory
387387
+ "007 001600 5.58529159E8 2\n"
388388
+ "007 001500 3.50730015E8 3\n"
389389
+ "007 003600 3.30874034E8 4\n");
390+
391+
public static WindowingTest NPATH = new WindowingTest(
392+
"testNPath",
393+
"Basic NPath test",
394+
" select origin_city_name, fl_num, year, month, day_of_month, sz, tpath " +
395+
" from npath( " +
396+
" flights_tiny " +
397+
" partition by fl_num " +
398+
" order by year, month, day_of_month, " +
399+
" 'LATE.LATE+', " +
400+
" 'LATE', arr_delay > 15, " +
401+
" 'origin_city_name, fl_num, year, month, day_of_month, size(tpath) as sz, tpath as tpath' " +
402+
" ) " +
403+
" into path='/tmp/testNPath' \n" +
404+
" serde 'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe' \n" +
405+
" with serdeproperties('field.delim'=',') \n" +
406+
" format 'org.apache.hadoop.mapred.TextOutputFormat'",
407+
"Baltimore 1142 2010 10 20 6 [{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":20,\"arr_delay\":23.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":21,\"arr_delay\":105.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":22,\"arr_delay\":54.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":25,\"arr_delay\":92.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":123.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":49.0,\"fl_num\":\"1142\"}]\n" +
408+
"Baltimore 1142 2010 10 21 5 [{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":21,\"arr_delay\":105.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":22,\"arr_delay\":54.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":25,\"arr_delay\":92.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":123.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":49.0,\"fl_num\":\"1142\"}]\n" +
409+
"Baltimore 1142 2010 10 22 4 [{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":22,\"arr_delay\":54.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":25,\"arr_delay\":92.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":123.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":49.0,\"fl_num\":\"1142\"}]\n" +
410+
"Baltimore 1142 2010 10 25 3 [{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":25,\"arr_delay\":92.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":123.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":49.0,\"fl_num\":\"1142\"}]\n" +
411+
"Baltimore 1142 2010 10 26 2 [{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":123.0,\"fl_num\":\"1142\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":49.0,\"fl_num\":\"1142\"}]\n" +
412+
"Chicago 1531 2010 10 21 2 [{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":21,\"arr_delay\":53.0,\"fl_num\":\"1531\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":22,\"arr_delay\":16.0,\"fl_num\":\"1531\"}]\n" +
413+
"Chicago 1531 2010 10 25 3 [{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":25,\"arr_delay\":43.0,\"fl_num\":\"1531\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":29.0,\"fl_num\":\"1531\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":70.0,\"fl_num\":\"1531\"}]\n" +
414+
"Chicago 1531 2010 10 26 2 [{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":29.0,\"fl_num\":\"1531\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":70.0,\"fl_num\":\"1531\"}]\n" +
415+
"Baltimore 1599 2010 10 21 2 [{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":21,\"arr_delay\":28.0,\"fl_num\":\"1599\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":22,\"arr_delay\":18.0,\"fl_num\":\"1599\"}]\n" +
416+
"Baltimore 1599 2010 10 25 3 [{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":25,\"arr_delay\":106.0,\"fl_num\":\"1599\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":90.0,\"fl_num\":\"1599\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":92.0,\"fl_num\":\"1599\"}]\n" +
417+
"Baltimore 1599 2010 10 26 2 [{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":26,\"arr_delay\":90.0,\"fl_num\":\"1599\"},{\"origin_city_name\":\"Baltimore\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":92.0,\"fl_num\":\"1599\"}]\n" +
418+
"Chicago 361 2010 10 20 2 [{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":20,\"arr_delay\":42.0,\"fl_num\":\"361\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":21,\"arr_delay\":142.0,\"fl_num\":\"361\"}]\n" +
419+
"Washington 7291 2010 10 27 2 [{\"origin_city_name\":\"Washington\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":27,\"arr_delay\":26.0,\"fl_num\":\"7291\"},{\"origin_city_name\":\"Washington\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":28,\"arr_delay\":45.0,\"fl_num\":\"7291\"}]\n" +
420+
"Chicago 897 2010 10 20 4 [{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":20,\"arr_delay\":24.0,\"fl_num\":\"897\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":21,\"arr_delay\":77.0,\"fl_num\":\"897\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":22,\"arr_delay\":24.0,\"fl_num\":\"897\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":24,\"arr_delay\":113.0,\"fl_num\":\"897\"}]\n" +
421+
"Chicago 897 2010 10 21 3 [{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":21,\"arr_delay\":77.0,\"fl_num\":\"897\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":22,\"arr_delay\":24.0,\"fl_num\":\"897\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":24,\"arr_delay\":113.0,\"fl_num\":\"897\"}]\n" +
422+
"Chicago 897 2010 10 22 2 [{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":22,\"arr_delay\":24.0,\"fl_num\":\"897\"},{\"origin_city_name\":\"Chicago\",\"dest_city_name\":\"New York\",\"year\":2010,\"month\":10,\"day_of_month\":24,\"arr_delay\":113.0,\"fl_num\":\"897\"}]\n");
390423

391424
public static Object[][] TESTS = new Object[][]
392425
{ new Object[] { BASIC },

0 commit comments

Comments
 (0)