Class DataApiOpDispenser

java.lang.Object

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

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

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<DataApiBaseOp,DataApiSpace>

io.nosqlbench.adapter.dataapi.opdispensers.DataApiOpDispenser

All Implemented Interfaces:

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

Direct Known Subclasses:

DataApiCountDocumentsOpDispenser, DataApiCreateCollectionOpDispenser, DataApiCreateCollectionWithClassOpDispenser, DataApiCreateDatabaseOpDispenser, DataApiCreateNamespaceOpDispenser, DataApiDeleteAllOpDispenser, DataApiDeleteManyOpDispenser, DataApiDeleteOneOpDispenser, DataApiDropCollectionOpDispenser, DataApiDropDatabaseOpDispenser, DataApiDropNamespaceOpDispenser, DataApiEstimatedDocumentCountOpDispenser, DataApiFindByIdOpDispenser, DataApiFindDistinctOpDispenser, DataApiFindOneAndDeleteOpDispenser, DataApiFindOneAndReplaceOpDispenser, DataApiFindOneAndUpdateOpDispenser, DataApiFindOneOpDispenser, DataApiFindOpDispenser, DataApiFindVectorFilterOpDispenser, DataApiFindVectorOpDispenser, DataApiGetDatabaseInfoOpDispenser, DataApiInsertManyOpDispenser, DataApiInsertOneOpDispenser, DataApiInsertOneVectorOpDispenser, DataApiListCollectionNamesOpDispenser, DataApiListCollectionsOpDispenser, DataApiListDatabasesOpDispenser, DataApiListNamespacesOpDispenser, DataApiReplaceOneOpDispenser, DataApiUpdateManyOpDispenser, DataApiUpdateOneOpDispenser

public abstract class DataApiOpDispenser
extends BaseOpDispenser<DataApiBaseOp,DataApiSpace>

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<DataApiSpace>	spaceFunction
protected final LongFunction<String>	targetFunction

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

EXPECTED_RESULT, logger, 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

Modifier	Constructor	Description
protected	DataApiOpDispenser(DriverAdapter<? extends DataApiBaseOp,DataApiSpace> adapter, ParsedOp op, LongFunction<String> targetFunction)

Method Summary

Modifier and Type	Method	Description
protected void	addOperatorFilter(List<com.datastax.astra.client.model.Filter> filtersList, String operator, String fieldName, Object fieldValue)
protected com.datastax.astra.client.model.CollectionOptions	getCollectionOptionsFromOp(ParsedOp op, long l)
protected com.datastax.astra.client.model.Filter	getFilterFromOp(ParsedOp op, long l)
protected com.datastax.astra.client.model.Projection[]	getProjectionFromOp(ParsedOp op, long l)
protected com.datastax.astra.client.model.Sort	getSortFromOp(ParsedOp op, long l)
protected com.datastax.astra.client.model.Update	getUpdates(ParsedOp op, long l)
protected float[]	getVectorValues(ParsedOp op, long l)
protected float[]	getVectorValues(Object rawVectorValues)
protected float[]	getVectorValuesList(Object rawVectorValues)

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

targetFunction

protected final LongFunction<String> targetFunction

spaceFunction

protected final LongFunction<DataApiSpace> spaceFunction

Constructor Details

DataApiOpDispenser

protected DataApiOpDispenser(DriverAdapter<? extends DataApiBaseOp,DataApiSpace> adapter,
 ParsedOp op,
 LongFunction<String> targetFunction)

Method Details

getSortFromOp

protected com.datastax.astra.client.model.Sort getSortFromOp(ParsedOp op,
 long l)

getFilterFromOp

protected com.datastax.astra.client.model.Filter getFilterFromOp(ParsedOp op,
 long l)

addOperatorFilter

protected void addOperatorFilter(List<com.datastax.astra.client.model.Filter> filtersList,
 String operator,
 String fieldName,
 Object fieldValue)

getUpdates

protected com.datastax.astra.client.model.Update getUpdates(ParsedOp op,
 long l)

getVectorValues

protected float[] getVectorValues(ParsedOp op,
 long l)

getVectorValues

protected float[] getVectorValues(Object rawVectorValues)

getVectorValuesList

protected float[] getVectorValuesList(Object rawVectorValues)

getProjectionFromOp

protected com.datastax.astra.client.model.Projection[] getProjectionFromOp(ParsedOp op,
 long l)

getCollectionOptionsFromOp

protected com.datastax.astra.client.model.CollectionOptions getCollectionOptionsFromOp(ParsedOp op,
 long l)