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

restore tag filtering diagnostics

Browse Source
This commit is contained in:
Jonathan Shook
2023-01-19 16:52:57 -06:00
parent 4175e79549
commit a85c38f15e
1 changed files with 9 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
adapters-api/src/main/java/io/nosqlbench/engine/api/activityconfig/yaml/StmtsDocList.java
View File

@@ -1,5 +1,5 @@
/* /*
* Copyright (c) 2022 nosqlbench * Copyright (c) 2022-2023 nosqlbench
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@@ -41,13 +41,6 @@ public class StmtsDocList implements Iterable<StmtsDoc> {
this.rawStmtsDocList = rawStmtsDocList; this.rawStmtsDocList = rawStmtsDocList;
} }
public List<StmtsDoc> getStmtDocs(String tagFilter) {
TagFilter tf = new TagFilter(tagFilter);
return getStmtDocs().stream()
.filter(tf::matchesTagged)
.collect(Collectors.toList());
}
public List<StmtsDoc> getStmtDocs() { public List<StmtsDoc> getStmtDocs() {
return rawStmtsDocList.getStmtsDocs().stream() return rawStmtsDocList.getStmtsDocs().stream()
.map(StmtsDoc::new) .map(StmtsDoc::new)
@@ -65,15 +58,17 @@ public class StmtsDocList implements Iterable<StmtsDoc> {
*/ */
public List<OpTemplate> getStmts(String tagFilterSpec) { public List<OpTemplate> getStmts(String tagFilterSpec) {
TagFilter ts = new TagFilter(tagFilterSpec); TagFilter ts = new TagFilter(tagFilterSpec);
List<OpTemplate> opTemplates = new ArrayList<>();
List<OpTemplate> allOpTemplates = getStmtDocs().stream()
getStmtDocs().stream()
.flatMap(d -> d.getStmts().stream()) .flatMap(d -> d.getStmts().stream())
.filter(ts::matchesTagged) .collect(Collectors.toList());
.forEach(opTemplates::add);
return opTemplates; List<OpTemplate> filteredOpTemplates = ts.filter(allOpTemplates);
for (String log : ts.filterLog(allOpTemplates)) {
logger.debug(log);
}
return filteredOpTemplates;
} }