reformat src/main

Author: brokkoli71

src/main/java/dev/zarr/zarrjava/ZarrException.java

@@ -2,11 +2,11 @@
 
 public class ZarrException extends Exception {
 
-  public ZarrException(String message, Throwable cause) {
-    super(message, cause);
-  }
+    public ZarrException(String message, Throwable cause) {
+        super(message, cause);
+    }
 
-  public ZarrException(String message) {
-    super(message);
-  }
+    public ZarrException(String message) {
+        super(message);
+    }
 }

src/main/java/dev/zarr/zarrjava/core/Array.java

@@ -1,12 +1,12 @@
 package dev.zarr.zarrjava.core;
 
 import dev.zarr.zarrjava.ZarrException;
+import dev.zarr.zarrjava.core.codec.CodecPipeline;
 import dev.zarr.zarrjava.store.FilesystemStore;
 import dev.zarr.zarrjava.store.StoreHandle;
 import dev.zarr.zarrjava.utils.IndexingUtils;
 import dev.zarr.zarrjava.utils.MultiArrayUtils;
 import dev.zarr.zarrjava.utils.Utils;
-import dev.zarr.zarrjava.core.codec.CodecPipeline;
 import ucar.ma2.InvalidRangeException;
 
 import javax.annotation.Nonnull;
@@ -21,6 +21,7 @@
 public abstract class Array extends AbstractNode {
 
     protected CodecPipeline codecPipeline;
+
     public abstract ArrayMetadata metadata();
 
     protected Array(StoreHandle storeHandle) throws ZarrException {
@@ -47,7 +48,8 @@ public static Array open(StoreHandle storeHandle) throws IOException, ZarrExcept
             throw new ZarrException("No Zarr array found at the specified location.");
         }
     }
-     /**
+
+    /**
      * Opens an existing Zarr array at a specified storage location. Automatically detects the Zarr version.
      *
      * @param path the storage location of the Zarr array
@@ -94,32 +96,32 @@ public void write(long[] offset, ucar.ma2.Array array, boolean parallel) {
             chunkStream = chunkStream.parallel();
         }
         chunkStream.forEach(
-            chunkCoords -> {
-                try {
-                    final IndexingUtils.ChunkProjection chunkProjection =
-                        IndexingUtils.computeProjection(chunkCoords, metadata.shape, chunkShape, offset,
-                            shape
-                        );
-
-                    ucar.ma2.Array chunkArray;
-                    if (IndexingUtils.isFullChunk(chunkProjection.chunkOffset, chunkProjection.shape,
-                        chunkShape
-                    )) {
-                        chunkArray = array.sectionNoReduce(chunkProjection.outOffset,
-                            chunkProjection.shape,
-                            null
-                        );
-                    } else {
-                        chunkArray = readChunk(chunkCoords);
-                        MultiArrayUtils.copyRegion(array, chunkProjection.outOffset, chunkArray,
-                            chunkProjection.chunkOffset, chunkProjection.shape
-                        );
+                chunkCoords -> {
+                    try {
+                        final IndexingUtils.ChunkProjection chunkProjection =
+                                IndexingUtils.computeProjection(chunkCoords, metadata.shape, chunkShape, offset,
+                                        shape
+                                );
+
+                        ucar.ma2.Array chunkArray;
+                        if (IndexingUtils.isFullChunk(chunkProjection.chunkOffset, chunkProjection.shape,
+                                chunkShape
+                        )) {
+                            chunkArray = array.sectionNoReduce(chunkProjection.outOffset,
+                                    chunkProjection.shape,
+                                    null
+                            );
+                        } else {
+                            chunkArray = readChunk(chunkCoords);
+                            MultiArrayUtils.copyRegion(array, chunkProjection.outOffset, chunkArray,
+                                    chunkProjection.chunkOffset, chunkProjection.shape
+                            );
+                        }
+                        writeChunk(chunkCoords, chunkArray);
+                    } catch (ZarrException | InvalidRangeException e) {
+                        throw new RuntimeException(e);
                     }
-                    writeChunk(chunkCoords, chunkArray);
-                } catch (ZarrException | InvalidRangeException e) {
-                    throw new RuntimeException(e);
-                }
-            });
+                });
 
     }
 
@@ -246,7 +248,7 @@ boolean chunkIsInArray(long[] chunkCoords) {
         final int[] chunkShape = metadata().chunkShape();
         for (int dimIdx = 0; dimIdx < metadata().ndim(); dimIdx++) {
             if (chunkCoords[dimIdx] < 0
-                || chunkCoords[dimIdx] * chunkShape[dimIdx] >= metadata().shape[dimIdx]) {
+                    || chunkCoords[dimIdx] * chunkShape[dimIdx] >= metadata().shape[dimIdx]) {
                 return false;
             }
         }
@@ -282,47 +284,47 @@ public ucar.ma2.Array read(final long[] offset, final int[] shape, final boolean
         }
 
         final ucar.ma2.Array outputArray = ucar.ma2.Array.factory(metadata.dataType().getMA2DataType(),
-            shape);
+                shape);
         Stream<long[]> chunkStream = Arrays.stream(IndexingUtils.computeChunkCoords(metadata.shape, chunkShape, offset, shape));
         if (parallel) {
             chunkStream = chunkStream.parallel();
         }
         chunkStream.forEach(
-            chunkCoords -> {
-                try {
-                    final IndexingUtils.ChunkProjection chunkProjection =
-                        IndexingUtils.computeProjection(chunkCoords, metadata.shape, chunkShape, offset,
-                            shape
-                        );
-
-                    if (chunkIsInArray(chunkCoords)) {
-                        MultiArrayUtils.copyRegion(metadata.allocateFillValueChunk(),
-                            chunkProjection.chunkOffset, outputArray, chunkProjection.outOffset,
-                            chunkProjection.shape
-                        );
+                chunkCoords -> {
+                    try {
+                        final IndexingUtils.ChunkProjection chunkProjection =
+                                IndexingUtils.computeProjection(chunkCoords, metadata.shape, chunkShape, offset,
+                                        shape
+                                );
+
+                        if (chunkIsInArray(chunkCoords)) {
+                            MultiArrayUtils.copyRegion(metadata.allocateFillValueChunk(),
+                                    chunkProjection.chunkOffset, outputArray, chunkProjection.outOffset,
+                                    chunkProjection.shape
+                            );
+                        }
+
+                        final String[] chunkKeys = metadata.chunkKeyEncoding().encodeChunkKey(chunkCoords);
+                        final StoreHandle chunkHandle = storeHandle.resolve(chunkKeys);
+                        if (!chunkHandle.exists()) {
+                            return;
+                        }
+                        if (codecPipeline.supportsPartialDecode()) {
+                            final ucar.ma2.Array chunkArray = codecPipeline.decodePartial(chunkHandle,
+                                    Utils.toLongArray(chunkProjection.chunkOffset), chunkProjection.shape);
+                            MultiArrayUtils.copyRegion(chunkArray, new int[metadata.ndim()], outputArray,
+                                    chunkProjection.outOffset, chunkProjection.shape
+                            );
+                        } else {
+                            MultiArrayUtils.copyRegion(readChunk(chunkCoords), chunkProjection.chunkOffset,
+                                    outputArray, chunkProjection.outOffset, chunkProjection.shape
+                            );
+                        }
+
+                    } catch (ZarrException e) {
+                        throw new RuntimeException(e);
                     }
-
-                    final String[] chunkKeys = metadata.chunkKeyEncoding().encodeChunkKey(chunkCoords);
-                    final StoreHandle chunkHandle = storeHandle.resolve(chunkKeys);
-                    if (!chunkHandle.exists()) {
-                        return;
-                    }
-                    if (codecPipeline.supportsPartialDecode()) {
-                        final ucar.ma2.Array chunkArray = codecPipeline.decodePartial(chunkHandle,
-                            Utils.toLongArray(chunkProjection.chunkOffset), chunkProjection.shape);
-                        MultiArrayUtils.copyRegion(chunkArray, new int[metadata.ndim()], outputArray,
-                            chunkProjection.outOffset, chunkProjection.shape
-                        );
-                    } else {
-                        MultiArrayUtils.copyRegion(readChunk(chunkCoords), chunkProjection.chunkOffset,
-                            outputArray, chunkProjection.outOffset, chunkProjection.shape
-                        );
-                    }
-
-                } catch (ZarrException e) {
-                    throw new RuntimeException(e);
-                }
-            });
+                });
         return outputArray;
     }