diff --git a/gradoop-flink/src/test/java/org/gradoop/flink/io/impl/csv/CSVTestBase.java b/gradoop-flink/src/test/java/org/gradoop/flink/io/impl/csv/CSVTestBase.java index ee397b62a026..f5e40a4469d4 100644 --- a/gradoop-flink/src/test/java/org/gradoop/flink/io/impl/csv/CSVTestBase.java +++ b/gradoop-flink/src/test/java/org/gradoop/flink/io/impl/csv/CSVTestBase.java @@ -143,6 +143,7 @@ protected void checkProperties(EPGMElement epgmElement) { assertTrue(epgmElement.hasProperty(GradoopTestUtils.KEY_c)); assertTrue(epgmElement.hasProperty(GradoopTestUtils.KEY_d)); assertTrue(epgmElement.hasProperty(GradoopTestUtils.KEY_e)); + assertTrue(epgmElement.hasProperty(GradoopTestUtils.KEY_f)); // assert that the properties have valid data types assertTrue(epgmElement.getPropertyValue(GradoopTestUtils.KEY_0).isBoolean()); @@ -160,6 +161,7 @@ protected void checkProperties(EPGMElement epgmElement) { assertTrue(epgmElement.getPropertyValue(GradoopTestUtils.KEY_c).isList()); assertTrue(epgmElement.getPropertyValue(GradoopTestUtils.KEY_d).isList()); assertTrue(epgmElement.getPropertyValue(GradoopTestUtils.KEY_e).isShort()); + assertTrue(epgmElement.getPropertyValue(GradoopTestUtils.KEY_e).isNull()); // assert that the properties have valid values assertEquals(epgmElement.getPropertyValue(GradoopTestUtils.KEY_0).getBoolean(), @@ -192,6 +194,8 @@ protected void checkProperties(EPGMElement epgmElement) { PROPERTY_MAP.get(GradoopTestUtils.KEY_d)); assertEquals(epgmElement.getPropertyValue(GradoopTestUtils.KEY_e).getShort(), PROPERTY_MAP.get(GradoopTestUtils.KEY_e)); + assertEquals(epgmElement.getPropertyValue(GradoopTestUtils.KEY_f).getShort(), + PROPERTY_MAP.get(GradoopTestUtils.KEY_f)); } /** @@ -215,5 +219,6 @@ protected void checkMetadataCsvLine(String line) { assertTrue(line.contains(GradoopTestUtils.KEY_c + ":list:string")); assertTrue(line.contains(GradoopTestUtils.KEY_d + ":list:int")); assertTrue(line.contains(GradoopTestUtils.KEY_e + ":short")); + assertTrue(line.contains(GradoopTestUtils.KEY_f + ":null")); } }