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

packagename refactoring

Browse Source
This commit is contained in:
Jonathan Shook 2022-08-16 00:42:49 -05:00
parent 6e929e7047
commit f255c5ec09
8 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/VirtDataMainApp.java
View File

@ -20,7 +20,7 @@ import io.nosqlbench.api.spi.BundledApp;
import io.nosqlbench.nb.annotations.Service;
import io.nosqlbench.virtdata.userlibs.apps.diagnoseapp.VirtDataDiagnoseApp;
import io.nosqlbench.virtdata.userlibs.apps.docsapp.VirtDataGenDocsApp;
import io.nosqlbench.virtdata.userlibs.apps.valuesapp.VirtDataCheckPerfApp;
import io.nosqlbench.virtdata.userlibs.apps.valuechecker.VirtDataCheckPerfApp;
import java.util.Arrays;

2
virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuesapp/IndexedThreadFactory.java → virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuechecker/IndexedThreadFactory.java
View File

@ -14,7 +14,7 @@
* limitations under the License.
*/
package io.nosqlbench.virtdata.userlibs.apps.valuesapp;
package io.nosqlbench.virtdata.userlibs.apps.valuechecker;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

2
virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuesapp/LongHistogram.java → virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuechecker/LongHistogram.java
View File

@ -14,7 +14,7 @@
* limitations under the License.
*/
package io.nosqlbench.virtdata.userlibs.apps.valuesapp;
package io.nosqlbench.virtdata.userlibs.apps.valuechecker;
public class LongHistogram implements PostProcessor {

2
virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuesapp/PostProcessor.java → virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuechecker/PostProcessor.java
View File

@ -14,7 +14,7 @@
* limitations under the License.
*/
package io.nosqlbench.virtdata.userlibs.apps.valuesapp;
package io.nosqlbench.virtdata.userlibs.apps.valuechecker;
public interface PostProcessor extends AutoCloseable {
void process(Object[] values);

2
virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuesapp/RunData.java → virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuechecker/RunData.java
View File

@ -14,7 +14,7 @@
* limitations under the License.
*/
package io.nosqlbench.virtdata.userlibs.apps.valuesapp;
package io.nosqlbench.virtdata.userlibs.apps.valuechecker;
public class RunData {
public String spec;

4
virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuesapp/ValuesCheckerCoordinator.java → virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuechecker/ValuesCheckerCoordinator.java
View File

@ -14,7 +14,7 @@
* limitations under the License.
*/
package io.nosqlbench.virtdata.userlibs.apps.valuesapp;
package io.nosqlbench.virtdata.userlibs.apps.valuechecker;
import io.nosqlbench.virtdata.core.bindings.DataMapper;
import io.nosqlbench.virtdata.core.bindings.VirtData;
@ -36,7 +36,6 @@ public class ValuesCheckerCoordinator implements Callable<RunData> {
private final long end;
private final long start;
private final boolean isolated;
// private final Semaphore semaphore;
private final ReentrantLock lock;
private final Condition goTime;
private final ConcurrentLinkedDeque<Throwable> errors = new ConcurrentLinkedDeque<>();
@ -60,7 +59,6 @@ public class ValuesCheckerCoordinator implements Callable<RunData> {
this.start = start;
this.end = end;
this.isolated = isolated;
// this.semaphore = new Semaphore(threads,false);
this.lock = new ReentrantLock();
this.goTime = lock.newCondition();
}

2
virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuesapp/ValuesCheckerExceptionHandler.java → virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuechecker/ValuesCheckerExceptionHandler.java
View File

@ -14,7 +14,7 @@
* limitations under the License.
*/
package io.nosqlbench.virtdata.userlibs.apps.valuesapp;
package io.nosqlbench.virtdata.userlibs.apps.valuechecker;
public class ValuesCheckerExceptionHandler implements Thread.UncaughtExceptionHandler {

4
virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuesapp/ValuesCheckerRunnable.java → virtdata-userlibs/src/main/java/io/nosqlbench/virtdata/userlibs/apps/valuechecker/ValuesCheckerRunnable.java
View File

@ -14,12 +14,12 @@
* limitations under the License.
*/
package io.nosqlbench.virtdata.userlibs.apps.valuesapp;
package io.nosqlbench.virtdata.userlibs.apps.valuechecker;
import io.nosqlbench.virtdata.core.bindings.DataMapper;
import io.nosqlbench.virtdata.core.bindings.VirtData;
import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Arrays;
import java.util.List;