forked from D-Net/dnet-hadoop
[Country Propagation] left out from previous commit
This commit is contained in:
parent
2b643059fa
commit
4437f9345d
|
@ -315,7 +315,7 @@ public class CountryPropagationJobTest {
|
||||||
Assertions.assertEquals(2, countries.size());
|
Assertions.assertEquals(2, countries.size());
|
||||||
Assertions.assertTrue(countries.stream().anyMatch(cs -> cs.getClassid().equals("IT") && cs.getClassname().equals("Italy")));
|
Assertions.assertTrue(countries.stream().anyMatch(cs -> cs.getClassid().equals("IT") && cs.getClassname().equals("Italy")));
|
||||||
Assertions.assertTrue(countries.stream().anyMatch(cs -> cs.getClassid().equals("NL") && cs.getClassname().equals("Netherlands")));
|
Assertions.assertTrue(countries.stream().anyMatch(cs -> cs.getClassid().equals("NL") && cs.getClassname().equals("Netherlands")));
|
||||||
|
|
||||||
countries = tmp.filter(r -> r.getId().equals("50|355e65625b88::54a1c76f520bb2c8da27d12e42891088")).collect().get(0).getCountry();
|
countries = tmp.filter(r -> r.getId().equals("50|355e65625b88::54a1c76f520bb2c8da27d12e42891088")).collect().get(0).getCountry();
|
||||||
Assertions.assertEquals(2, countries.size());
|
Assertions.assertEquals(2, countries.size());
|
||||||
Assertions.assertTrue(countries.stream().anyMatch(cs -> cs.getClassid().equals("IT") && cs.getClassname().equals("Italy")));
|
Assertions.assertTrue(countries.stream().anyMatch(cs -> cs.getClassid().equals("IT") && cs.getClassname().equals("Italy")));
|
||||||
|
|
Loading…
Reference in New Issue