Class GCPSpannerInsertOpDispenser

java.lang.Object

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

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

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<GCPSpannerBaseOp<?,?>,GCPSpannerSpace>

io.nosqlbench.adapter.gcpspanner.opdispensers.GCPSpannerBaseOpDispenser<GCPSpannerInsertOp,com.google.cloud.Timestamp>

io.nosqlbench.adapter.gcpspanner.opdispensers.GCPSpannerInsertOpDispenser

All Implemented Interfaces:

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

public class GCPSpannerInsertOpDispenser
extends GCPSpannerBaseOpDispenser<GCPSpannerInsertOp,com.google.cloud.Timestamp>

This class is responsible for dispensing GCP Spanner insert vector operations. It extends the GCPSpannerBaseOpDispenser and provides the necessary implementation to create and configure GCPSpannerInsertVectorOp instances.

Nested Class Summary

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

NBLabeledElement.BasicLabeledElement

Field Summary

Fields inherited from class io.nosqlbench.adapter.gcpspanner.opdispensers.GCPSpannerBaseOpDispenser

spaceFunction, targetFunction

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
GCPSpannerInsertOpDispenser(GCPSpannerDriverAdapter adapter, ParsedOp op, LongFunction<String> targetFunction)	Constructs a new GCPSpannerInsertVectorOpDispenser.

Method Summary

Modifier and Type	Method	Description
GCPSpannerInsertOp	getOp(long cycle)	Returns a GCPSpannerInsertVectorOp instance configured with the provided value.

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

Constructor Details

GCPSpannerInsertOpDispenser

public GCPSpannerInsertOpDispenser(GCPSpannerDriverAdapter adapter,
 ParsedOp op,
 LongFunction<String> targetFunction)

Constructs a new GCPSpannerInsertVectorOpDispenser.

Parameters:

adapter - the GCP Spanner driver adapter

op - the parsed operation

targetFunction - a function that provides the target table name based on a long value

Method Details

getOp

public GCPSpannerInsertOp getOp(long cycle)

Returns a GCPSpannerInsertVectorOp instance configured with the provided value.

Parameters:

cycle - the value used to configure the operation

Returns:

a configured GCPSpannerInsertVectorOp instance