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

organize cql op functions

Browse Source
This commit is contained in:
Jonathan Shook 2020-05-29 11:07:31 -05:00
parent fd25ea2391
commit eb41be7e4f
7 changed files with 29 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/core/CqlAction.java
View File

@ -13,6 +13,7 @@ import io.nosqlbench.activitytype.cql.errorhandling.exceptions.MaxTriesExhausted
import io.nosqlbench.activitytype.cql.errorhandling.exceptions.UnexpectedPagingException;
import io.nosqlbench.activitytype.cql.statements.core.ReadyCQLStatement;
import com.google.common.util.concurrent.ListenableFuture;
import io.nosqlbench.activitytype.cql.statements.modifiers.StatementModifier;
import io.nosqlbench.engine.api.activityapi.core.ActivityDefObserver;
import io.nosqlbench.engine.api.activityapi.core.MultiPhaseAction;
import io.nosqlbench.engine.api.activityapi.core.SyncAction;

1
driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/core/CqlActivity.java
View File

@ -14,6 +14,7 @@ import io.nosqlbench.activitytype.cql.errorhandling.NBCycleErrorHandler;
import io.nosqlbench.activitytype.cql.errorhandling.HashedCQLErrorHandler;
import io.nosqlbench.activitytype.cql.statements.binders.CqlBinderTypes;
import io.nosqlbench.activitytype.cql.statements.core.*;
import io.nosqlbench.activitytype.cql.statements.modifiers.StatementModifier;
import io.nosqlbench.activitytype.cql.statements.rowoperators.RowCycleOperators;
import io.nosqlbench.activitytype.cql.statements.rowoperators.Save;
import io.nosqlbench.activitytype.cql.statements.rsoperators.ResultSetCycleOperators;

1
driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/core/CqlAsyncAction.java
View File

@ -15,6 +15,7 @@ import io.nosqlbench.activitytype.cql.errorhandling.exceptions.UnexpectedPagingE
import io.nosqlbench.activitytype.cql.statements.core.ReadyCQLStatement;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import io.nosqlbench.activitytype.cql.statements.modifiers.StatementModifier;
import io.nosqlbench.engine.api.activityapi.core.BaseAsyncAction;
import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.FailedOp;
import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.StartedOp;

11
driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/statements/modifiers/StartTimerOp.java Normal file
View File

@ -0,0 +1,11 @@
package io.nosqlbench.activitytype.cql.statements.modifiers;
import com.datastax.driver.core.Statement;
public class StartTimerOp implements StatementModifier {
@Override
public Statement modify(Statement unmodified, long cycleNum) {
return null;
}
}

2
driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/core/StatementModifier.java → driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/statements/modifiers/StatementModifier.java
View File

@ -1,4 +1,4 @@
package io.nosqlbench.activitytype.cql.core;
package io.nosqlbench.activitytype.cql.statements.modifiers;
import com.datastax.driver.core.Statement;

13
driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/statements/rsoperators/StopTimerOp.java Normal file
View File

@ -0,0 +1,13 @@
package io.nosqlbench.activitytype.cql.statements.rsoperators;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Statement;
import io.nosqlbench.activitytype.cql.api.ResultSetCycleOperator;
public class StopTimerOp implements ResultSetCycleOperator {
@Override
public int apply(ResultSet resultSet, Statement statement, long cycle) {
return 0;
}
}

2
driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/statements/rsoperators/TraceLogger.java
View File

@ -5,7 +5,7 @@ import com.datastax.driver.core.QueryTrace;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Statement;
import io.nosqlbench.activitytype.cql.api.ResultSetCycleOperator;
import io.nosqlbench.activitytype.cql.core.StatementModifier;
import io.nosqlbench.activitytype.cql.statements.modifiers.StatementModifier;
import io.nosqlbench.engine.api.util.SimpleConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;