Rust implementation of the CVM algorithm for counting distinct elements in a stream
Merge pull request #1 from kuldeepmeel/main
author
Stephan Hügel
committer
GitHub
date
(May 24, 2024, 9:03 AM +0100)
commit
ec8edb2a
ec8edb2a468de5009b313a99da8c7f1fc538e4c6
parent
bfcd5267
bfcd5267ead792a4a048fc38d4fe0ed1151457f8
+1
-4
+1
-4
src/lib.rs
+1
-4
src/lib.rs
···
51
51
if self.rng.gen_bool(self.probability) {
52
52
self.buf.push(clean_word);
53
53
}
54
-
if self.buf.len() == self.buf_size {
54
+
while self.buf.len() == self.buf_size {
55
55
self.clear_about_half();
56
56
self.probability /= 2.0;
57
-
if self.buf.len() == self.buf_size {
58
-
panic!("Something has gone proper wrong")
59
-
}
60
57
}
61
58
}
62
59
}