IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

vectorizing find one op

Browse Source
This commit is contained in:
Mark Wolters 2024-05-10 17:49:20 -04:00
parent 085b7b969e
commit d5a96e81c4
2 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nb-adapters/adapter-dataapi/src/main/java/io/nosqlbench/adapter/dataapi/opdispensers/DataApiFindOneOpDispenser.java
View File

@ -55,8 +55,9 @@ public class DataApiFindOneOpDispenser extends DataApiOpDispenser {
private FindOneOptions getFindOneOptions(ParsedOp op, long l) { private FindOneOptions getFindOneOptions(ParsedOp op, long l) {
FindOneOptions options = new FindOneOptions(); FindOneOptions options = new FindOneOptions();
Sort sort = getSortFromOp(op, l); Sort sort = getSortFromOp(op, l);
float[] vector = getVectorValues(op, l);
if (sort != null) { if (sort != null) {
options = options.sort(sort); options = vector != null ? options.sort(vector, sort) : options.sort(sort);
} }
Projection[] projection = getProjectionFromOp(op, l); Projection[] projection = getProjectionFromOp(op, l);
if (projection != null) { if (projection != null) {

17
nb-adapters/adapter-dataapi/src/main/java/io/nosqlbench/adapter/dataapi/opdispensers/DataApiOpDispenser.java
View File

@ -127,6 +127,11 @@ public abstract class DataApiOpDispenser extends BaseOpDispenser<DataApiBaseOp,
return update; return update;
} }
protected float[] getVectorValues(ParsedOp op, long l) {
Object rawVectorValues = op.get("vector", l);
return getVectorValues(rawVectorValues);
}
protected float[] getVectorValues(Object rawVectorValues) { protected float[] getVectorValues(Object rawVectorValues) {
float[] floatValues; float[] floatValues;
if (rawVectorValues instanceof String) { if (rawVectorValues instanceof String) {
@ -135,12 +140,24 @@ public abstract class DataApiOpDispenser extends BaseOpDispenser<DataApiBaseOp,
for (int i = 0; i < rawValues.length; i++) { for (int i = 0; i < rawValues.length; i++) {
floatValues[i] = Float.parseFloat(rawValues[i]); floatValues[i] = Float.parseFloat(rawValues[i]);
} }
} else if (rawVectorValues instanceof List) {
return getVectorValuesList(rawVectorValues);
} else { } else {
throw new RuntimeException("Invalid type specified for values"); throw new RuntimeException("Invalid type specified for values");
} }
return floatValues; return floatValues;
} }
protected float[] getVectorValuesList(Object rawVectorValues) {
float[] vectorValues = null;
List<Object> vectorValuesList = (List<Object>) rawVectorValues;
vectorValues = new float[vectorValuesList.size()];
for (int i = 0; i < vectorValuesList.size(); i++) {
vectorValues[i] = Float.parseFloat(vectorValuesList.get(i).toString());
}
return vectorValues;
}
protected Projection[] getProjectionFromOp(ParsedOp op, long l) { protected Projection[] getProjectionFromOp(ParsedOp op, long l) {
Projection[] projection = null; Projection[] projection = null;
Optional<LongFunction<Map>> projectionFunction = op.getAsOptionalFunction("projection", Map.class); Optional<LongFunction<Map>> projectionFunction = op.getAsOptionalFunction("projection", Map.class);