Class KafkaBaseOpDispenser

java.lang.Object

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

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

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<KafkaOp,KafkaSpace>

io.nosqlbench.adapter.kafka.dispensers.KafkaBaseOpDispenser

All Implemented Interfaces:

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

Direct Known Subclasses:

MessageConsumerOpDispenser, MessageProducerOpDispenser

public abstract class KafkaBaseOpDispenser
extends BaseOpDispenser<KafkaOp,KafkaSpace>

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 boolean	asyncAPI
protected final int	consumerGrpCnt
protected final KafkaAdapterMetrics	kafkaAdapterMetrics
protected final int	kafkaClntCnt
protected final KafkaSpace	kafkaSpace
protected final ParsedOp	parsedOp
protected final Map<String,String>	topicConfMap
protected final LongFunction<String>	topicNameStrFunc
protected final long	totalCycleNum
protected final int	totalThreadNum

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

Modifier	Constructor	Description
protected	KafkaBaseOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> topicNameStrFunc, KafkaSpace kafkaSpace)

Method Summary

Modifier and Type	Method	Description
KafkaAdapterMetrics	getKafkaAdapterMetrics()
KafkaSpace	getKafkaSpace()
String	getName()
protected LongFunction<String>	lookupMandtoryStrOpValueFunc(String paramName)
protected LongFunction<String>	lookupOptionalStrOpValueFunc(String paramName)
protected LongFunction<String>	lookupOptionalStrOpValueFunc(String paramName, String defaultValue)
protected LongFunction<Boolean>	lookupStaticBoolConfigValueFunc(String paramName, boolean defaultValue)

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

parsedOp

protected final ParsedOp parsedOp

kafkaAdapterMetrics

protected final KafkaAdapterMetrics kafkaAdapterMetrics

kafkaSpace

protected final KafkaSpace kafkaSpace

kafkaClntCnt

protected final int kafkaClntCnt

consumerGrpCnt

protected final int consumerGrpCnt

asyncAPI

protected final boolean asyncAPI

topicNameStrFunc

protected final LongFunction<String> topicNameStrFunc

topicConfMap

protected final Map<String,String> topicConfMap

totalThreadNum

protected final int totalThreadNum

totalCycleNum

protected final long totalCycleNum

Constructor Details

KafkaBaseOpDispenser

protected KafkaBaseOpDispenser(DriverAdapter adapter,
 ParsedOp op,
 LongFunction<String> topicNameStrFunc,
 KafkaSpace kafkaSpace)

Method Details

getKafkaSpace

public KafkaSpace getKafkaSpace()

getKafkaAdapterMetrics

public KafkaAdapterMetrics getKafkaAdapterMetrics()

lookupStaticBoolConfigValueFunc

protected LongFunction<Boolean> lookupStaticBoolConfigValueFunc(String paramName,
 boolean defaultValue)

lookupOptionalStrOpValueFunc

protected LongFunction<String> lookupOptionalStrOpValueFunc(String paramName,
 String defaultValue)

lookupOptionalStrOpValueFunc

protected LongFunction<String> lookupOptionalStrOpValueFunc(String paramName)

lookupMandtoryStrOpValueFunc

protected LongFunction<String> lookupMandtoryStrOpValueFunc(String paramName)

getName

public String getName()