milvus/cpp/src/db/engine/ExecutionEngineImpl.h
Yu Kun 3d79ccd97b add GpuCacheMgr
Former-commit-id: c95181ef545748516cad9d3c0561fb8f753c6f37
2019-08-22 15:59:01 +08:00

87 lines
2.0 KiB
C++

/*******************************************************************************
* Copyright 上海赜睿信息科技有限公司(Zilliz) - All Rights Reserved
* Unauthorized copying of this file, via any medium is strictly prohibited.
* Proprietary and confidential.
******************************************************************************/
#pragma once
#include "ExecutionEngine.h"
#include "wrapper/knowhere/vec_index.h"
#include <memory>
#include <string>
namespace zilliz {
namespace milvus {
namespace engine {
class ExecutionEngineImpl : public ExecutionEngine {
public:
ExecutionEngineImpl(uint16_t dimension,
const std::string &location,
EngineType type);
ExecutionEngineImpl(VecIndexPtr index,
const std::string &location,
EngineType type);
Status AddWithIds(long n, const float *xdata, const long *xids) override;
size_t Count() const override;
size_t Size() const override;
size_t Dimension() const override;
size_t PhysicalSize() const override;
Status Serialize() override;
Status Load(bool to_cache) override;
Status CopyToGpu(uint64_t device_id) override;
Status CopyToCpu() override;
Status Merge(const std::string &location) override;
Status Search(long n,
const float *data,
long k,
long nprobe,
float *distances,
long *labels) const override;
ExecutionEnginePtr BuildIndex(const std::string &) override;
Status Cache() override;
Status GpuCache(uint64_t gpu_id) override;
Status Init() override;
private:
VecIndexPtr CreatetVecIndex(EngineType type);
VecIndexPtr Load(const std::string &location);
protected:
VecIndexPtr index_ = nullptr;
EngineType build_type;
EngineType current_type;
int64_t dim;
std::string location_;
size_t nlist_ = 0;
int64_t gpu_num = 0;
};
} // namespace engine
} // namespace milvus
} // namespace zilliz