Class QdrantBaseOpDispenser<REQUEST,RESULT>

java.lang.Object

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

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

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<QdrantBaseOp<?,?>,QdrantSpace>

io.nosqlbench.adapter.qdrant.opdispensers.QdrantBaseOpDispenser<REQUEST,RESULT>

All Implemented Interfaces:

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

Direct Known Subclasses:

QdrantCollectionExistsOpDispenser, QdrantCollectionInfoOpDispenser, QdrantCountPointsOpDispenser, QdrantCreateCollectionOpDispenser, QdrantCreatePayloadIndexOpDispenser, QdrantDeleteCollectionOpDispenser, QdrantListCollectionAliasesOpDispenser, QdrantListCollectionsOpDispenser, QdrantListSnapshotsOpDispenser, QdrantSearchPointsOpDispenser, QdrantUpsertPointsOpDispenser

public abstract class QdrantBaseOpDispenser<REQUEST,RESULT>
extends BaseOpDispenser<QdrantBaseOp<?,?>,QdrantSpace>

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<io.qdrant.client.QdrantClient>	clientFunction
protected final LongFunction<QdrantSpace>	qdrantSpaceFunction

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	QdrantBaseOpDispenser(QdrantDriverAdapter adapter, ParsedOp op, LongFunction<String> targetF)

Method Summary

Modifier and Type	Method	Description
abstract LongFunction<QdrantBaseOp<REQUEST,RESULT>>	createOpFunc(LongFunction<REQUEST> paramF, LongFunction<io.qdrant.client.QdrantClient> clientF, ParsedOp op, LongFunction<String> targetF)
protected LongFunction<io.qdrant.client.grpc.Points.Filter.Builder>	getFilterFromOp(ParsedOp op)	Builds the complete Points.Filter.Builder from the ParsedOp
QdrantBaseOp<REQUEST,RESULT>	getOp(long cycle)	This method should do all the work of creating an operation that is executable by some other caller.
abstract LongFunction<REQUEST>	getParamFunc(LongFunction<io.qdrant.client.QdrantClient> clientF, ParsedOp op, LongFunction<String> targetF)

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

Field Details

qdrantSpaceFunction

protected final LongFunction<QdrantSpace> qdrantSpaceFunction

clientFunction

protected final LongFunction<io.qdrant.client.QdrantClient> clientFunction

Constructor Details

QdrantBaseOpDispenser

protected QdrantBaseOpDispenser(QdrantDriverAdapter adapter,
 ParsedOp op,
 LongFunction<String> targetF)

Method Details

getParamFunc

public abstract LongFunction<REQUEST> getParamFunc(LongFunction<io.qdrant.client.QdrantClient> clientF,
 ParsedOp op,
 LongFunction<String> targetF)

createOpFunc

public abstract LongFunction<QdrantBaseOp<REQUEST,RESULT>> createOpFunc(LongFunction<REQUEST> paramF,
 LongFunction<io.qdrant.client.QdrantClient> clientF,
 ParsedOp op,
 LongFunction<String> targetF)

getOp

public QdrantBaseOp<REQUEST,RESULT> getOp(long cycle)

Description copied from interface: OpDispenser

This method should do all the work of creating an operation that is executable by some other caller. The value produced by the apply method should not require additional processing if a caller wants to execute the operation multiple times, as for retries.

Parameters:

cycle - The cycle number which serves as the seed for any generated op fields to be bound into an operation.

Returns:

an executable operation

getFilterFromOp

protected LongFunction<io.qdrant.client.grpc.Points.Filter.Builder> getFilterFromOp(ParsedOp op)

Builds the complete Points.Filter.Builder from the ParsedOp

Returns:

LongFunction<Filter.Builder>

See Also:

• Filtering