@@ -938,7 +938,7 @@ def tracking(self, other):
938
938
939
939
return i_self , i_other , cost_mat [i_self , i_other ]
940
940
941
- def to_zarr (self , handler ):
941
+ def to_zarr (self , handler , ** kwargs ):
942
942
handler .attrs ['track_extra_variables' ] = "," .join (self .track_extra_variables )
943
943
if self .track_array_variables != 0 :
944
944
handler .attrs ['track_array_variables' ] = self .track_array_variables
@@ -963,6 +963,7 @@ def to_zarr(self, handler):
963
963
scale_factor = VAR_DESCR [name ].get ("scale_factor" , None ),
964
964
add_offset = VAR_DESCR [name ].get ("add_offset" , None ),
965
965
filters = VAR_DESCR [name ].get ("filters" , None ),
966
+ ** kwargs
966
967
)
967
968
self .set_global_attr_zarr (handler )
968
969
@@ -1060,10 +1061,12 @@ def create_variable_zarr(
1060
1061
data ,
1061
1062
scale_factor = None ,
1062
1063
add_offset = None ,
1063
- filters = None
1064
+ filters = None ,
1065
+ compressor = None
1064
1066
):
1065
1067
kwargs_variable ['shape' ] = data .shape
1066
- kwargs_variable ['compressor' ] = zarr .Blosc (cname = 'zstd' , clevel = 5 , shuffle = zarr .blosc .BITSHUFFLE )
1068
+ kwargs_variable ['compressor' ] = \
1069
+ zarr .Blosc (cname = 'zstd' , clevel = 2 ) if compressor is None else compressor
1067
1070
kwargs_variable ['filters' ] = list ()
1068
1071
store_dtype = kwargs_variable .pop ('store_dtype' , None )
1069
1072
if scale_factor is not None or add_offset is not None :
0 commit comments