Skip to content

Commit 5784109

Browse files
committed
Remove aggregate_diskarray way as well
1 parent 03fc893 commit 5784109

File tree

3 files changed

+5
-10
lines changed

3 files changed

+5
-10
lines changed

src/auxil.jl

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,6 @@ function gdalcube(filenames::AbstractVector{<:AbstractString}, stackgroups=:lazy
154154

155155
#@show sdates
156156
# Put the dates which are 200 seconds apart into groups
157-
if stackgroups in [:dae, :lazyagg]
158157
groupinds = grouptimes(sdates, 200000)
159158
onefile = first(sfiles)
160159
gd = backendlist[:gdal]
@@ -173,13 +172,8 @@ function gdalcube(filenames::AbstractVector{<:AbstractString}, stackgroups=:lazy
173172

174173
cubelist = CFDiskArray.(group_gdbs, (gdbattrs,))
175174
stackinds = stackindices(sdates)
176-
aggdata = if stackgroups == :dae
177-
gcube = diskstack(cubelist)
178-
aggdata = DAE.aggregate_diskarray(gcube, mean skipmissing, (3 => stackinds,); strategy=:direct)
179-
else
180-
println("Construct lazy diskarray")
181-
LazyAggDiskArray(skipmissingmean, cubelist, stackinds)
182-
end
175+
println("Construct lazy diskarray")
176+
LazyAggDiskArray(skipmissingmean, cubelist, stackinds)
183177
# data = DiskArrays.ConcatDiskArray(reshape(groupcubes, (1,1,length(groupcubes))))
184178
dates_grouped = [sdates[group[begin]] for group in groupinds]
185179

src/main.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ function main(;
7777
orbit="D",
7878
threshold=3.0,
7979
folders=["V1M0R1", "V1M1R1", "V1M1R2"],
80-
stack=:dae,
80+
stack=:lazyagg,
8181
delete_intermediate=false
8282
)
8383
outdir = Path(outdir)

test/testdata.jl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,8 @@
2121
indir=indir,
2222
start_date=Date("2021-01-01"),
2323
end_date=Date("2022-01-01"),
24-
outdir=Path(outdir)
24+
outdir=Path(outdir),
25+
stack=:lazyagg,
2526
)
2627
a = open_dataset(joinpath(outdir, "E051N018T3_rqatrend_VH_D022_thresh_3.0_2021-01-01_2022-01-01.zarr")).layer
2728

0 commit comments

Comments
 (0)