org.apache.hedwig.client.benchmark

Class BenchmarkUtils.ThroughputLatencyAggregator

java.lang.Object

org.apache.hedwig.client.benchmark.BenchmarkUtils.ThroughputLatencyAggregator

Enclosing class:

BenchmarkUtils

public static class BenchmarkUtils.ThroughputLatencyAggregator
extends Object

Stats aggregator for callback (round-trip) operations. Measures both throughput and latency.

Constructor Summary

Constructors

Constructor and Description
ThroughputLatencyAggregator(String label, int count, int limit)

Method Summary

Modifier and Type	Method and Description
void	reportLatency(long latency)
void	startProgress()
String	summarize(long startTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThroughputLatencyAggregator

public ThroughputLatencyAggregator(String label,
                                   int count,
                                   int limit)
                            throws InterruptedException

Throws:

InterruptedException

Method Detail

startProgress

public void startProgress()

reportLatency

public void reportLatency(long latency)

summarize

public String summarize(long startTime)