Skip to content

Commit 749a954

Browse files
committed
small perf improvements in unique-* methods.
1 parent 7e44d35 commit 749a954

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/tech/v3/dataset/base.clj

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
[tech.v3.dataset.readers :as ds-readers]
2626
[tech.v3.dataset.dynamic-int-list :as dyn-int-list]
2727
[ham-fisted.api :as hamf]
28+
[ham-fisted.lazy-noncaching :as lznc]
2829
[ham-fisted.reduce :as hamf-rf]
2930
[ham-fisted.protocols :as hamf-proto]
3031
[ham-fisted.set :as set])
@@ -767,7 +768,7 @@
767768
map-fn]
768769
(when dataset
769770
(->> (group-by->indexes dataset map-fn)
770-
(map (fn [[k v]] (keep-fn k v)))
771+
(lznc/map (fn [kv] (keep-fn (key kv) (val kv))))
771772
(sorted-int32-sequence)
772773
(select-rows dataset))))
773774
([dataset map-fn]
@@ -786,7 +787,7 @@
786787
colname]
787788
(when dataset
788789
(->> (group-by-column->indexes dataset colname)
789-
(map (fn [[k v]] (keep-fn k v)))
790+
(lznc/map (fn [kv] (keep-fn (key kv) (val kv))))
790791
(sorted-int32-sequence)
791792
(select dataset :all))))
792793
([dataset colname]

0 commit comments

Comments
 (0)