@@ -73,7 +73,7 @@ auto vq_query_nth(const DB& db, const Q& q, int k, bool nth, int nthreads) {
7373 // For each database vector
7474 for (int i = db_start; i < db_stop; ++i) {
7575 // Compare with each query
76- for (int j = 0 ; j < size_q; ++j) {
76+ for (size_t j = 0 ; j < size_q; ++j) {
7777 // scores[j][i] = L2(q[j], db[i]);
7878 scores (i, j) = L2 (q[j], db[i]);
7979 }
@@ -126,19 +126,19 @@ auto vq_query_heap(DB& db, Q& q, int k, unsigned nthreads) {
126126 db,
127127 [&, size_q](auto && db_vec, auto && n = 0 , auto && i = 0 ) {
128128 if (block_db) {
129- for (int j = 0 ; j < size_q; ++j) {
129+ for (size_t j = 0 ; j < size_q; ++j) {
130130 auto score = L2 (q[j], db_vec);
131131 scores[n][j].insert (element{score, i + db.offset ()});
132132 }
133133
134134 } else if (block_q) {
135- for (int j = 0 ; j < size_q; ++j) {
135+ for (size_t j = 0 ; j < size_q; ++j) {
136136 auto score = L2 (q[j], db_vec);
137137 scores[n][j + q.offset ()].insert (element{score, i});
138138 }
139139
140140 } else {
141- for (int j = 0 ; j < size_q; ++j) {
141+ for (size_t j = 0 ; j < size_q; ++j) {
142142 auto score = L2 (q[j], db_vec);
143143 scores[n][j].insert (element{score, i});
144144 }
@@ -156,8 +156,8 @@ auto vq_query_heap(DB& db, Q& q, int k, unsigned nthreads) {
156156 }
157157 }
158158
159- for (int j = 0 ; j < size (q); ++j) {
160- for (int n = 1 ; n < nthreads; ++n) {
159+ for (size_t j = 0 ; j < size (q); ++j) {
160+ for (unsigned n = 1 ; n < nthreads; ++n) {
161161 for (auto && e : scores[n][j]) {
162162 scores[0 ][j].insert (e);
163163 }
@@ -263,4 +263,4 @@ auto vq_partition(const DB& db, const Q& q, int k, bool nth, int nthreads) {
263263#endif
264264} // namespace detail::flat
265265
266- #endif // TILEDB_FLAT_VQ_H
266+ #endif // TILEDB_FLAT_VQ_H
0 commit comments