...
| Code Block |
|---|
public class ImportParam {
private MinioDataSource data_source;
private List<DataFile> external_files;
} |
...
| 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 proxyProxy RPC Interfaces
The declaration of import API in proxy RPC:
| 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
}
|
Datacoord RPC interfaces
The RPC interface declaration of import API in datacoord RPC:
| 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
} |
Datanode RPC interfaces
The RPC interface declaration of import API in datanode RPC:
| Code Block |
|---|
service DataNode {
rpc Import(milvus.ImportRequest) returns(common.Status) {}
} |
...