Package com.zendesk.maxwell.producer

Class AbstractProfilingProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.AbstractProfilingProducer

Direct Known Subclasses:

ProfilerProducer

public abstract class AbstractProfilingProducer
extends AbstractProducer

Field Summary

Fields

Modifier and Type	Field	Description
protected long	count
protected long	startTime

Fields inherited from class com.zendesk.maxwell.producer.AbstractProducer

context, failedMessageCount, failedMessageMeter, messageLatencySloViolationCount, messageLatencyTimer, messagePublishTimer, outputConfig, succeededMessageCount, succeededMessageMeter

Constructor Summary

Constructors

Constructor	Description
AbstractProfilingProducer(MaxwellContext context)

Method Summary

Modifier and Type	Method	Description
void	push(RowMap r)

Methods inherited from class com.zendesk.maxwell.producer.AbstractProducer

getDiagnostic, getFailedMessageMeter, getStoppableTask

Methods inherited from class java.lang.Object

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

Field Detail

count

protected long count

startTime

protected long startTime

Constructor Detail

AbstractProfilingProducer

public AbstractProfilingProducer(MaxwellContext context)

Method Detail

push

public void push(RowMap r)
          throws Exception

Specified by:

push in class AbstractProducer

Throws:

Exception