@@ -129,9 +129,9 @@ public void testSelectFromPubsub() throws Exception {
129129
130130 assertThat (
131131 Arrays .asList (
132- Arrays .asList ("2018-07-01 21:25:20" , "enroute" , "40.702" , "-74.001" ),
133- Arrays .asList ("2018-07-01 21:26:06" , "enroute" , "40.703" , "-74.002" ),
134- Arrays .asList ("2018-07-02 13:26:06" , "enroute" , "30.0" , "-72.32324" )),
132+ Arrays .asList ("2018-07-01 21:25:20.000000 " , "enroute" , "40.702" , "-74.001" ),
133+ Arrays .asList ("2018-07-01 21:26:06.000000 " , "enroute" , "40.703" , "-74.002" ),
134+ Arrays .asList ("2018-07-02 13:26:06.000000 " , "enroute" , "30.0" , "-72.32324" )),
135135 everyItem (IsIn .isOneOf (expectedResult .get (30 , TimeUnit .SECONDS ).toArray ())));
136136 }
137137
@@ -170,8 +170,8 @@ public void testFilterForSouthManhattan() throws Exception {
170170
171171 assertThat (
172172 Arrays .asList (
173- Arrays .asList ("2018-07-01 21:25:20" , "enroute" , "40.701" , "-74.001" ),
174- Arrays .asList ("2018-07-01 21:26:06" , "enroute" , "40.702" , "-74.002" )),
173+ Arrays .asList ("2018-07-01 21:25:20.000000 " , "enroute" , "40.701" , "-74.001" ),
174+ Arrays .asList ("2018-07-01 21:26:06.000000 " , "enroute" , "40.702" , "-74.002" )),
175175 everyItem (IsIn .isOneOf (expectedResult .get (30 , TimeUnit .SECONDS ).toArray ())));
176176 }
177177
0 commit comments