File tree 1 file changed +7
-4
lines changed
1 file changed +7
-4
lines changed Original file line number Diff line number Diff line change 146
146
147
147
148
148
(defn add-missing-values!
149
- [^IMutList container ^RoaringBitmap missing
149
+ ^long [^IMutList container ^RoaringBitmap missing
150
150
missing-value ^long idx]
151
151
(let [n-elems (.size container)]
152
152
(when (< n-elems idx)
153
153
(.add missing (long n-elems) idx)
154
- (.addAllReducible container (hamf/repeat (- idx n-elems) missing-value)))))
154
+ (.addAllReducible container (hamf/repeat (- idx n-elems) missing-value)))
155
+ (- idx n-elems)))
155
156
156
157
157
158
(defn finalize-parser-data!
483
484
column-name
484
485
^:unsynchronized-mutable ^long last-idx
485
486
^:unsynchronized-mutable ^long max-idx
487
+ ^:unsynchronized-mutable ^long mc
486
488
options]
487
489
dtype-proto /PECount
488
490
(ecount [_this] (inc max-idx))
504
506
(let [; ;Avoid the pack call if possible
505
507
packed-dtype (packing/pack-datatype val-dtype)
506
508
container-ecount (.size container)
507
- logical-ecount (- container-ecount ( .getCardinality missing) )]
509
+ logical-ecount (- container-ecount mc )]
508
510
; ;Setup container
509
511
(if (== 0 logical-ecount)
510
512
(do
529
531
(set! missing-value (column-base/datatype->missing-value
530
532
widest-datatype))))))))
531
533
(when (> (- idx last-idx) 1 )
532
- (add-missing-values! container missing missing-value idx))
534
+ (set! mc ( + mc ( add-missing-values! container missing missing-value idx)) ))
533
535
(set! last-idx idx)
534
536
(.add container value))))
535
537
(finalize [_p rowcount]
546
548
column-name
547
549
-1
548
550
-1
551
+ 0
549
552
options))
You can’t perform that action at this time.
0 commit comments