@@ -318,13 +318,16 @@ function _check_and_normalize!(plt::Bar, all_args)
318318 end
319319
320320
321- if opts[:missingmode ] in (1 , 3 )
322- cp_ds = dropmissing (ds, col, threads = false , mapformats= all_args. mapformats, view= true )
323- elseif opts[:missingmode ] in (2 , 3 ) && opts[:group ] != = nothing
324- cp_ds = dropmissing (ds, opts[:group ], threads = false , mapformats= all_args. mapformats, view= true )
321+ if opts[:missingmode ] == 1
322+ cp_ds = dropmissing (ds, col, threads = threads, mapformats= all_args. mapformats, view= true )
323+ elseif opts[:missingmode ] == 2 && opts[:group ] != = nothing
324+ cp_ds = dropmissing (ds, opts[:group ], threads = threads, mapformats= all_args. mapformats, view= true )
325+ elseif opts[:missingmode ] == 3
326+ _cols = unique ([col, something (opts[:group ], col) ])
327+ cp_ds = dropmissing (ds, _cols, threads = threads, mapformats= all_args. mapformats, view= true )
325328 elseif opts[:missingmode ] == 4
326329 _cols = unique ([col, something (opts[:group ], col) ])
327- cp_ds = dropmissing (ds, _cols, threads = false , mapformats= all_args. mapformats, view= true )
330+ cp_ds = delete (ds, _cols, by = ismissing, threads = threads , mapformats= all_args. mapformats, view= true )
328331 else
329332 cp_ds = ds
330333 end
0 commit comments