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

cleanups

Browse Source
This commit is contained in:
Jonathan Shook 2024-04-05 18:43:18 -05:00
parent e99acba7a0
commit ee43c3a024
2 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
adapter-milvus/src/main/java/io/nosqlbench/adapter/milvus/ops/MilvusDescribeIndexOp.java
View File

@ -84,7 +84,7 @@ public class MilvusDescribeIndexOp extends MilvusBaseOp<DescribeIndexParam> impl
return stream().mapToInt(IndexStat::percent).min().orElse(0);
}
}
public static final record IndexStat(
public record IndexStat(
String index_name,
long indexed_rows,
long pending_rows

2
adapters-api/src/main/java/io/nosqlbench/adapters/api/scheduling/TimeoutPredicate.java
View File

@ -91,10 +91,8 @@ public class TimeoutPredicate<T> {
if (isComplete) {
return new Result<>(value, Status.complete, totalNanos, timeoutNanos, null);
} else if (remaining > 0) {
// System.out.println("pulse:" + pulseTime + " end:" + endNanos + " remaining:" + remaining);
return new Result<>(value, Status.pending, totalNanos, timeoutNanos, null);
} else {
// System.out.println("pulse:" + pulseTime + " end:" + endNanos + " remaining:" + remaining);
return new Result<>(value, Status.incomplete, totalNanos, timeoutNanos, null);
}
} catch (Exception e) {