File tree Expand file tree Collapse file tree 1 file changed +7
-4
lines changed
Expand file tree Collapse file tree 1 file changed +7
-4
lines changed Original file line number Diff line number Diff line change 146146
147147
148148(defn add-missing-values!
149- [^IMutList container ^RoaringBitmap missing
149+ ^long [^IMutList container ^RoaringBitmap missing
150150 missing-value ^long idx]
151151 (let [n-elems (.size container)]
152152 (when (< n-elems idx)
153153 (.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)))
155156
156157
157158(defn finalize-parser-data!
483484 column-name
484485 ^:unsynchronized-mutable ^long last-idx
485486 ^:unsynchronized-mutable ^long max-idx
487+ ^:unsynchronized-mutable ^long mc
486488 options]
487489 dtype-proto /PECount
488490 (ecount [_this] (inc max-idx))
504506 (let [; ;Avoid the pack call if possible
505507 packed-dtype (packing/pack-datatype val-dtype)
506508 container-ecount (.size container)
507- logical-ecount (- container-ecount ( .getCardinality missing) )]
509+ logical-ecount (- container-ecount mc )]
508510 ; ;Setup container
509511 (if (== 0 logical-ecount)
510512 (do
529531 (set! missing-value (column-base/datatype->missing-value
530532 widest-datatype))))))))
531533 (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)) ))
533535 (set! last-idx idx)
534536 (.add container value))))
535537 (finalize [_p rowcount]
546548 column-name
547549 -1
548550 -1
551+ 0
549552 options))
You can’t perform that action at this time.
0 commit comments