Class Cqld4BaseOpDispenser<T extends Cqld4BaseOp<?>>

java.lang.Object

io.nosqlbench.nb.api.components.core.NBBaseComponentMetrics

io.nosqlbench.nb.api.components.core.NBBaseComponent

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<T,Cqld4Space>

io.nosqlbench.adapter.cqld4.opdispensers.Cqld4BaseOpDispenser<T>

All Implemented Interfaces:

CqlOpMetrics, OpDispenser<T>, OpResultTracker, NBComponent, NBComponentAdvisors, NBComponentEvents, NBComponentMetrics, NBComponentProps, NBComponentServices, NBComponentTimeline, NBProviderSearch, NBTokenWords, NBLabeledElement, AutoCloseable, LongFunction<T>

Direct Known Subclasses:

Cqld4CqlBaseOpDispenser, Cqld4FluentGraphOpDispenser, Cqld4PreparedStmtDispenser, CqlD4RainbowTableDispenser, Cqld4SsTableDispenser

public abstract class Cqld4BaseOpDispenser<T extends Cqld4BaseOp<?>>
extends BaseOpDispenser<T,Cqld4Space>
implements CqlOpMetrics

Nested Class Summary

Nested classes/interfaces inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

NBLabeledElement.BasicLabeledElement

Field Summary

Fields

Modifier and Type	Field	Description
protected final LongFunction<com.datastax.oss.driver.api.core.CqlSession>	sessionF

Fields inherited from class io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser

EXPECTED_RESULT, spaceF, START_TIMERS, STOP_TIMERS, VERIFIER, VERIFIER_IMPORTS, VERIFIER_INIT, verifierTimer

Fields inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponent

bufferOrphanedMetrics, closed_ns, error, errored_ns, metricsBuffer, parent, started_epoch_ms, started_ns, state, teardown_ns

Fields inherited from interface io.nosqlbench.nb.api.components.core.NBComponent

EMPTY_COMPONENT

Fields inherited from interface io.nosqlbench.nb.api.components.core.NBComponentProps

HDRDIGITS, SUMMARY

Fields inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

EMPTY

Constructor Summary

Constructors

Constructor	Description
Cqld4BaseOpDispenser(Cqld4DriverAdapter adapter, ParsedOp op)

Method Summary

Modifier and Type	Method	Description
protected <S extends com.datastax.oss.driver.api.core.cql.Statement> LongFunction<S>	getEnhancedStmtFunc(LongFunction<S> basefunc, ParsedOp op)	All implementations of a CQL Statement Dispenser should be using the method provided by this function.
int	getMaxLwtRetries()
int	getMaxPages()
boolean	isRetryReplace()
void	recordFetchedBytes(int bytes)
void	recordFetchedPages(int pages)
void	recordFetchedRows(int rows)

Methods inherited from class io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser

apply, getLabels, getOpName, getVerifier, onError, onStart, onSuccess

Methods inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponent

addAdvisor, addMetricsCloseable, attachChild, beforeDetach, close, create, detachChild, find, findParentService, getAdvisors, getChildren, getComponentOnlyLabels, getComponentProp, getComponentState, getNanosSinceStart, getParent, getTokens, nanosof_close, nanosof_error, nanosof_start, nanosof_teardown, onError, onEvent, reportExecutionMetric, setComponentProp, started_epoch_ms, teardown, toString

Methods inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponentMetrics

addComponentMetric, addListener, findComponentMetrics, findComponentMetrics, getComponentMetric, getComponentMetrics, removeListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.nosqlbench.nb.api.components.core.NBComponentAdvisors

getAdvisorResults

Methods inherited from interface io.nosqlbench.nb.api.components.core.NBComponentMetrics

addComponentMetric, findComponentMetrics, findComponentMetrics, findOneComponentMetric, findOneComponentMetric, getComponentMetric, getComponentMetrics

Methods inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

description

Methods inherited from interface io.nosqlbench.adapters.api.activityimpl.OpDispenser

getOp

Field Details

sessionF

protected final LongFunction<com.datastax.oss.driver.api.core.CqlSession> sessionF

Constructor Details

Cqld4BaseOpDispenser

public Cqld4BaseOpDispenser(Cqld4DriverAdapter adapter,
 ParsedOp op)

Method Details

getMaxPages

public int getMaxPages()

isRetryReplace

public boolean isRetryReplace()

getMaxLwtRetries

public int getMaxLwtRetries()

getEnhancedStmtFunc

protected <S extends com.datastax.oss.driver.api.core.cql.Statement>
LongFunction<S> getEnhancedStmtFunc(LongFunction<S> basefunc,
 ParsedOp op)

All implementations of a CQL Statement Dispenser should be using the method provided by this function. This ensures that Statement-level attributes are handled uniformly and in one place.

This takes the base statement function and decorates it optionally with each additional qualified modifier, short-circuiting those which are not specified. This allows default behavior to take precedence as well as avoids unnecessary calling overhead for implicit attributes. This should be called when the stmt function is initialized within each dispenser, not for each time dispensing occurs.

recordFetchedRows

public void recordFetchedRows(int rows)

Specified by:

recordFetchedRows in interface CqlOpMetrics

recordFetchedPages

public void recordFetchedPages(int pages)

Specified by:

recordFetchedPages in interface CqlOpMetrics

recordFetchedBytes

public void recordFetchedBytes(int bytes)

Specified by:

recordFetchedBytes in interface CqlOpMetrics