make sure normalized data set does not already exist

saalfeldlab · Mar 13, 2024 · 8ed4e44 · 8ed4e44
1 parent f485215
commit 8ed4e44
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/org/janelia/saalfeldlab/hotknife/SparkNormalizeN5.java b/src/main/java/org/janelia/saalfeldlab/hotknife/SparkNormalizeN5.java
@@ -121,6 +121,11 @@ public static void main(final String... args) throws IOException, InterruptedExc
 		final String outputDataset = options.n5DatasetInput + "_normalized" + invertedName;
 		final String fullScaleOutputDataset = outputDataset + "/s0";
 
+		if (n5Output.exists(fullScaleOutputDataset)) {
+			final String fullPath = options.n5PathInput + fullScaleOutputDataset;
+			throw new IllegalArgumentException("Normalized data set exists: " + fullPath);
+		}
+
 		n5Output.createDataset(fullScaleOutputDataset, dimensions, blockSize, DataType.UINT8, new GzipCompression());
 
 		final JavaRDD<long[][]> pGrid = sparkContext.parallelize(grid);