Class OpTimeTrackKafkaClient

java.lang.Object

io.nosqlbench.adapter.kafka.ops.OpTimeTrackKafkaClient

Direct Known Subclasses:

OpTimeTrackKafkaConsumer, OpTimeTrackKafkaProducer

public abstract class OpTimeTrackKafkaClient
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	activityStartTime
protected final KafkaSpace	kafkaSpace
protected final long	maxOpTimeInSec

Constructor Summary

Constructors

Constructor	Description
OpTimeTrackKafkaClient(KafkaSpace kafkaSpace)

Method Summary

Modifier and Type	Method	Description
abstract void	close()
void	process(long cycle, Object cycleObj)

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

activityStartTime

protected final long activityStartTime

maxOpTimeInSec

protected final long maxOpTimeInSec

Constructor Details

OpTimeTrackKafkaClient

public OpTimeTrackKafkaClient(KafkaSpace kafkaSpace)

Method Details

process

public void process(long cycle,
 Object cycleObj)

close

public abstract void close()