Class KafkaOp

java.lang.Object

io.nosqlbench.adapter.kafka.ops.KafkaOp

All Implemented Interfaces:

CycleOp<Object>, LongFunction<Object>

public class KafkaOp
extends Object
implements CycleOp<Object>

Field Summary

Fields

Modifier and Type	Field	Description
protected final KafkaSpace	kafkaSpace
protected final com.codahale.metrics.Histogram	messageSizeHistogram

Constructor Summary

Constructors

Constructor	Description
KafkaOp(KafkaAdapterMetrics kafkaAdapterMetrics, KafkaSpace kafkaSpace, OpTimeTrackKafkaClient opTimeTrackKafkaClient, Object cycleObj)

Method Summary

Modifier and Type	Method	Description
Object	apply(long value)	Run an action for the given cycle.

Methods inherited from class java.lang.Object

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

Field Details

kafkaSpace

protected final KafkaSpace kafkaSpace

messageSizeHistogram

protected final com.codahale.metrics.Histogram messageSizeHistogram

Constructor Details

KafkaOp

public KafkaOp(KafkaAdapterMetrics kafkaAdapterMetrics,
 KafkaSpace kafkaSpace,
 OpTimeTrackKafkaClient opTimeTrackKafkaClient,
 Object cycleObj)

Method Details

apply

public Object apply(long value)

Description copied from interface: CycleOp

Run an action for the given cycle.

Specified by:

apply in interface CycleOp<Object>

Specified by:

apply in interface LongFunction<Object>

Parameters:

value - The cycle value for which an operation is run