Skip to content

Commit 4be63f8

Browse files
committed
bug fix
1 parent 1f63c55 commit 4be63f8

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/abstractdataset/dscol.jl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -113,11 +113,13 @@ Base.findmin(f, col::SubOrDSCol) = findmin(f, __!(col))
113113
Base.findmin(col::SubOrDSCol) = findmin(identity, __!(col))
114114
Base.cumsum(col::SubOrDSCol; missings=:ignore) = cumsum(__!(col), missings=missings)
115115
Base.cumprod(col::SubOrDSCol; missings=:ignore) = cumprod(__!(col), missings=missings)
116+
IMD.cumsum(col::SubOrDSCol; missings=:ignore) = cumsum(__!(col), missings=missings)
117+
IMD.cumprod(col::SubOrDSCol; missings=:ignore) = cumprod(__!(col), missings=missings)
116118
cummin(col::SubOrDSCol; missings=:ignore) = cummin(__!(col), missings=missings)
117119
cummax(col::SubOrDSCol; missings=:ignore) = cummax(__!(col), missings=missings)
118120

119-
topk(col::SubOrDSCol, k; rev=false, lt = <, by = identity, threads = true) = topk(__!(col), k, rev=rev, lt = lt, by = by, threads = threads)
120-
topkperm(col::SubOrDSCol, k; rev=false, lt = <, by = identity, threads = true) = topkperm(__!(col), k, rev=rev, lt = lt, by = by, threads = threads)
121+
topk(col::SubOrDSCol, k; rev=false, lt=<, by=identity, threads=true) = topk(__!(col), k, rev=rev, lt=lt, by=by, threads=threads)
122+
topkperm(col::SubOrDSCol, k; rev=false, lt=<, by=identity, threads=true) = topkperm(__!(col), k, rev=rev, lt=lt, by=by, threads=threads)
121123
lag(col::SubOrDSCol; default=missing) = lag(__!(col), default=default)
122124
lag(col::SubOrDSCol, k; default=missing) = lag(__!(col), k, default=default)
123125
lead(col::SubOrDSCol; default=missing) = lead(__!(col), default=default)

0 commit comments

Comments
 (0)