...
Code Block |
---|
rpc Import(ImportRequest) returns (MutationResult) {} message ImportRequest { common.MsgBase base = 1; string options = 2; // the json options string } message MutationResult { common.Status status = 1; schema.IDs IDs = 2; // return auto-id for insert/import, deleted id for delete repeated uint32 succ_index = 3; // succeed indexes for insert/import repeated uint32 err_index = 4; // error indexes for insert/import bool acknowledged = 5; int64 insert_cnt = 6; // how many entities were inserted or imported int64 delete_cnt = 7; int64 upsert_cnt = 8; uint64 timestamp = 9; } |
Internal machinery
The RPC interface of proxy:
Code Block |
---|
service MilvusService {
rpc Import(ImportRequest) returns (ImportResponse) {}
}
message ImportRequest {
common.MsgBase base = 1;
string options = 2; // options in JSON format
}
message ImportResponse {
common.Status status = 1;
repeated schema.IDs IDs = 2; // auto-generated ids for succeed chunks
uint32 succ_index = 3; // number of chunks that successfully imported
}
|
The RPC interface of datacoord:
Code Block |
---|
service DataCoord {
rpc Import(milvuspb.ImportRequest) (milvuspb.ImportResponse) {}
rpc CompleteImport(ImportResult) returns (common.Status) {}
}
message ImportResult {
common.Status status = 1;
schema.IDs IDs = 2; // auto-generated ids
repeated int64 segments = 3; // id array of new sealed segments
} |
The RPC interface of datanode:
Code Block |
---|
service DataNode {
rpc Import(milvus.ImportRequest) returns(common.Status) {}
} |