IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2024-12-25 08:11:06 -06:00
Code Issues Packages Projects Releases Wiki Activity

basic test working for rampup

Browse Source
This commit is contained in:
Jonathan Shook 2024-03-21 14:28:21 -05:00
parent 798291eda1
commit c0e25f8b74
3 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
adapter-milvus/src/main/java/io/nosqlbench/adapter/milvus/MilvusOpMapper.java
View File

@ -61,9 +61,9 @@ public class MilvusOpMapper implements OpMapper<MilvusBaseOp<?>> {
case create_index -> new MilvusCreateIndexOpDispenser(adapter, op, typeAndTarget.targetFunction); case create_index -> new MilvusCreateIndexOpDispenser(adapter, op, typeAndTarget.targetFunction);
case drop_index -> new MilvusDropIndexOpDispenser(adapter, op, typeAndTarget.targetFunction); case drop_index -> new MilvusDropIndexOpDispenser(adapter, op, typeAndTarget.targetFunction);
// Uses the Collection-specific fields (columnar) insert mode // Uses the Collection-specific fields (columnar) insert mode
case insert_fields -> new MilvusInsertOpDispenser(adapter, op, typeAndTarget.targetFunction);
// Uses the High-Level row-by-row JSONObject (tabular) insert mode
case insert_rows -> new MilvusInsertRowsOpDispenser(adapter, op, typeAndTarget.targetFunction); case insert_rows -> new MilvusInsertRowsOpDispenser(adapter, op, typeAndTarget.targetFunction);
// Uses the High-Level row-by-row JSONObject (tabular) insert mode
case insert -> new MilvusInsertOpDispenser(adapter, op, typeAndTarget.targetFunction);
case delete -> new MilvusDeleteOpDispenser(adapter, op, typeAndTarget.targetFunction); case delete -> new MilvusDeleteOpDispenser(adapter, op, typeAndTarget.targetFunction);
case search -> new MilvusSearchOpDispenser(adapter, op, typeAndTarget.targetFunction); case search -> new MilvusSearchOpDispenser(adapter, op, typeAndTarget.targetFunction);
case alter_alias -> new MilvusAlterAliasOpDispenser(adapter, op, typeAndTarget.targetFunction); case alter_alias -> new MilvusAlterAliasOpDispenser(adapter, op, typeAndTarget.targetFunction);

2
adapter-milvus/src/main/java/io/nosqlbench/adapter/milvus/types/MilvusOpType.java
View File

@ -45,8 +45,8 @@ public enum MilvusOpType {
get_persistent_segment_info(Collection), get_persistent_segment_info(Collection),
get_query_segment_info(Collection), get_query_segment_info(Collection),
get_replicas(Collection), get_replicas(Collection),
insert_fields(Collection),
insert_rows(Collection), // Added because of generic signature causing ambiguous patterns on insert(...) insert_rows(Collection), // Added because of generic signature causing ambiguous patterns on insert(...)
insert(Collection),
load_collection(Collection), load_collection(Collection),
release_collection(Collection), release_collection(Collection),
show_collections(Collection), show_collections(Collection),

6
adapter-milvus/src/main/resources/activities/milvus.yaml
View File

@ -36,6 +36,7 @@ scenarios:
params: params:
driver: milvus driver: milvus
instrument: true instrument: true
database: TEMPLATE(database)
bindings: bindings:
row_key: ToString() row_key: ToString()
@ -103,9 +104,12 @@ blocks:
# https://milvus.io/api-reference/java/v2.3.x/Collection/insert().md # https://milvus.io/api-reference/java/v2.3.x/Collection/insert().md
insert_op: insert_op:
insert: "TEMPLATE(collection,vector)" insert: "TEMPLATE(collection,vector)"
fields: rows:
key: "{row_key}" key: "{row_key}"
value: "{train_floatlist_TEMPLATE(filetype,hdf5)}" value: "{train_floatlist_TEMPLATE(filetype,hdf5)}"
# fields:
# key: (List this) "{row_key}"
# value: (List this) "{train_floatlist_TEMPLATE(filetype,hdf5)}"
search: search:
ops: ops: