GeoJsonReader extends RddReader { public static SpatialRDD<Geometry> readToGeometryRDD(JavaSparkContext sc, String inputPath) { return readToGeometryRDD(sc, inputPath, true, false); }  static SpatialRDD<Geometry> readToGeometryRDD(JavaSparkContext sc, String inputPath); static SpatialRDD<Geometry> readToGeometryRDD(JavaSparkContext sc, String inputPath, boolean allowInvalidGeometries, boolean skipSyntacticallyInvalidGeometries); static SpatialRDD<Geometry> readToGeometryRDD(JavaRDD rawTextRDD); static SpatialRDD<Geometry> readToGeometryRDD(JavaRDD rawTextRDD, boolean allowInvalidGeometries, boolean skipSyntacticallyInvalidGeometries);  }
@Test public void testReadToGeometryRDD() throws IOException { SpatialRDD geojsonRDD = GeoJsonReader.readToGeometryRDD(sc, geoJsonGeomWithFeatureProperty); assertEquals(geojsonRDD.rawSpatialRDD.count(), 1001); geojsonRDD = GeoJsonReader.readToGeometryRDD(sc, geoJsonGeomWithoutFeatureProperty); assertEquals(geojsonRDD.rawSpatialRDD.count(), 10); }
@Test public void testReadToGeometryRDDWithNullValue() throws IOException { SpatialRDD geojsonRDD = GeoJsonReader.readToGeometryRDD(sc, geoJsonWithNullProperty); assertEquals(geojsonRDD.rawSpatialRDD.count(), 3); }
@Test public void testReadToValidGeometryRDD() throws IOException { SpatialRDD geojsonRDD = GeoJsonReader.readToGeometryRDD(sc, geoJsonGeomWithFeatureProperty, true, false); assertEquals(geojsonRDD.rawSpatialRDD.count(), 1001); geojsonRDD = GeoJsonReader.readToGeometryRDD(sc, geoJsonGeomWithoutFeatureProperty, true, false); assertEquals(geojsonRDD.rawSpatialRDD.count(), 10); geojsonRDD = GeoJsonReader.readToGeometryRDD(sc, geoJsonWithInvalidGeometries, false,false); assertEquals(geojsonRDD.rawSpatialRDD.count(), 2); geojsonRDD = GeoJsonReader.readToGeometryRDD(sc, geoJsonWithInvalidGeometries); assertEquals(geojsonRDD.rawSpatialRDD.count(), 3); }
@Test public void testReadToIncludIdRDD() throws IOException { SpatialRDD geojsonRDD = GeoJsonReader.readToGeometryRDD(sc,geoJsonContainsId,true,false); assertEquals(geojsonRDD.rawSpatialRDD.count(),1); assertEquals(geojsonRDD.fieldNames.size(), 3); }