Class Cqld4CqlOp

java.lang.Object

io.nosqlbench.adapter.cqld4.optypes.Cqld4CqlOp

All Implemented Interfaces:

Cqld4BaseOp<List<com.datastax.oss.driver.api.core.cql.Row>>, CycleOp<List<com.datastax.oss.driver.api.core.cql.Row>>, OpGenerator, OpResultSize, UniformVariableCapture<List<com.datastax.oss.driver.api.core.cql.Row>>, LongFunction<List<com.datastax.oss.driver.api.core.cql.Row>>

Direct Known Subclasses:

Cqld4CqlBatchStatement, Cqld4CqlOpImpl, Cqld4CqlPreparedStatement, Cqld4CqlReboundStatement, Cqld4CqlSimpleStatement

public abstract class Cqld4CqlOp
extends Object
implements Cqld4BaseOp<List<com.datastax.oss.driver.api.core.cql.Row>>, UniformVariableCapture<List<com.datastax.oss.driver.api.core.cql.Row>>, OpGenerator, OpResultSize

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Cqld4CqlOp.PrintableRowList

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Cqld4CqlOp(com.datastax.oss.driver.api.core.CqlSession session, int maxPages, boolean retryReplace, int maxLwtRetries, int retryReplaceCount, RSProcessors processors, CqlOpMetrics metrics)
	Cqld4CqlOp(com.datastax.oss.driver.api.core.CqlSession session, int maxPages, boolean retryReplace, int maxLwtRetries, RSProcessors processors, CqlOpMetrics metrics)

Method Summary

Modifier and Type	Method	Description
List<com.datastax.oss.driver.api.core.cql.Row>	apply(long cycle)	Run an action for the given cycle.
CycleOp<?>	getNextOp()
abstract String	getQueryString()
abstract com.datastax.oss.driver.api.core.cql.Statement<?>	getStmt()
Function<List<com.datastax.oss.driver.api.core.cql.Row>,Map<String,?>>	initCaptureF(CapturePoints<List<com.datastax.oss.driver.api.core.cql.Row>> points)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.nosqlbench.adapters.api.activityimpl.uniform.flowtypes.OpResultSize

getResultSize

Constructor Details

Cqld4CqlOp

public Cqld4CqlOp(com.datastax.oss.driver.api.core.CqlSession session,
 int maxPages,
 boolean retryReplace,
 int maxLwtRetries,
 RSProcessors processors,
 CqlOpMetrics metrics)

Cqld4CqlOp

protected Cqld4CqlOp(com.datastax.oss.driver.api.core.CqlSession session,
 int maxPages,
 boolean retryReplace,
 int maxLwtRetries,
 int retryReplaceCount,
 RSProcessors processors,
 CqlOpMetrics metrics)

Method Details

apply

public List<com.datastax.oss.driver.api.core.cql.Row> apply(long cycle)

Description copied from interface: CycleOp

Run an action for the given cycle.

Specified by:

apply in interface CycleOp<List<com.datastax.oss.driver.api.core.cql.Row>>

Specified by:

apply in interface LongFunction<List<com.datastax.oss.driver.api.core.cql.Row>>

Parameters:

cycle - The cycle value for which an operation is run

getNextOp

public CycleOp<?> getNextOp()

Specified by:

getNextOp in interface OpGenerator

initCaptureF

public Function<List<com.datastax.oss.driver.api.core.cql.Row>,Map<String,?>> initCaptureF(CapturePoints<List<com.datastax.oss.driver.api.core.cql.Row>> points)

Specified by:

initCaptureF in interface UniformVariableCapture<List<com.datastax.oss.driver.api.core.cql.Row>>

getStmt

public abstract com.datastax.oss.driver.api.core.cql.Statement<?> getStmt()

getQueryString

public abstract String getQueryString()