test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-01 03:18:29 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

Format TimestampIndex.cpp (#12764)

Browse Source 
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
This commit is contained in:
Cai Yudong 2021-12-06 18:07:31 +08:00 committed by GitHub
parent 69902378cc
commit 35cd7b5689
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
internal/core/src/segcore/TimestampIndex.cpp
View File

@ -9,13 +9,15 @@
// is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
// or implied. See the License for the specific language governing permissions and limitations under the License
#include <segcore/TimestampIndex.h>
#include "TimestampIndex.h"
namespace milvus::segcore {
void
TimestampIndex::set_length_meta(std::vector<int64_t> lengths) {
lengths_ = std::move(lengths);
}
void
TimestampIndex::build_with(const Timestamp* timestamps, int64_t size) {
auto num_slice = lengths_.size();
@ -45,6 +47,7 @@ TimestampIndex::build_with(const Timestamp* timestamps, int64_t size) {
this->max_timestamp_ = last_max_v;
this->timestamp_barriers_ = std::move(timestamp_barriers);
}
std::pair<int64_t, int64_t>
TimestampIndex::get_active_range(Timestamp query_timestamp) const {
if (query_timestamp >= max_timestamp_) {
@ -59,6 +62,7 @@ TimestampIndex::get_active_range(Timestamp query_timestamp) const {
Assert(0 <= block_id && block_id < lengths_.size());
return {start_locs_[block_id], start_locs_[block_id + 1]};
}
boost::dynamic_bitset<>
TimestampIndex::GenerateBitset(Timestamp query_timestamp,
std::pair<int64_t, int64_t> active_range,
@ -101,4 +105,5 @@ GenerateFakeSlices(const Timestamp* timestamps, int64_t size, int min_slice_leng
results.push_back(slice_length);
return results;
}
} // namespace milvus::segcore