diff --git a/src/hazard/src/main/java/gov/usgs/earthquake/nshmp/netcdf/reader/BoundingReaderHazardCurves.java b/src/hazard/src/main/java/gov/usgs/earthquake/nshmp/netcdf/reader/BoundingReaderHazardCurves.java index b982fd1ff2bf494614d6b6e72f3b633dfb3ea72a..5a928af53e945df60d90839aa2a4f3e61c65e480 100644 --- a/src/hazard/src/main/java/gov/usgs/earthquake/nshmp/netcdf/reader/BoundingReaderHazardCurves.java +++ b/src/hazard/src/main/java/gov/usgs/earthquake/nshmp/netcdf/reader/BoundingReaderHazardCurves.java @@ -2,8 +2,12 @@ package gov.usgs.earthquake.nshmp.netcdf.reader; import java.io.IOException; import java.util.List; +import java.util.logging.Logger; import java.util.stream.Collectors; +import com.google.common.math.DoubleMath; + +import gov.usgs.earthquake.nshmp.Maths; import gov.usgs.earthquake.nshmp.data.XySequence; import gov.usgs.earthquake.nshmp.geo.Location; import gov.usgs.earthquake.nshmp.netcdf.Netcdf; @@ -27,6 +31,8 @@ import ucar.nc2.dataset.NetcdfDatasets; */ public class BoundingReaderHazardCurves extends BoundingReader<StaticDataHazardCurves> { + private static final double FILL_VALUE = 9999.9; + public BoundingReaderHazardCurves(NetcdfHazardCurves netcdf, Location site) { super(netcdf, site); } @@ -150,7 +156,7 @@ public class BoundingReaderHazardCurves extends BoundingReader<StaticDataHazardC (double[]) hazards.section(origin, shape).reduce().get1DJavaArray(DataType.DOUBLE)); var points = xySequence.stream() - .filter(xy -> !Double.isNaN(xy.y())) + .filter(xy -> Maths.round(xy.x(), 1) != FILL_VALUE) .collect(Collectors.toList()); var xs = points.stream().map(xy -> xy.x()).collect(Collectors.toList());