org.apache.hedwig.client.benchmark

Class BenchmarkSubscriber

java.lang.Object

org.apache.hedwig.client.benchmark.BenchmarkWorker

org.apache.hedwig.client.benchmark.BenchmarkSubscriber

All Implemented Interfaces:

Callable<Void>

public class BenchmarkSubscriber
extends BenchmarkWorker
implements Callable<Void>

Constructor Summary

Constructors

Constructor and Description
BenchmarkSubscriber(int numTopics, int numMessages, int numRegions, int startTopicLabel, int partitionIndex, int numPartitions, Subscriber subscriber, com.google.protobuf.ByteString subId)

Method Summary

Modifier and Type	Method and Description
Void	call()
void	warmup(int numWarmup)

Methods inherited from class java.lang.Object

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

Constructor Detail

BenchmarkSubscriber

public BenchmarkSubscriber(int numTopics,
                           int numMessages,
                           int numRegions,
                           int startTopicLabel,
                           int partitionIndex,
                           int numPartitions,
                           Subscriber subscriber,
                           com.google.protobuf.ByteString subId)

Method Detail

warmup

public void warmup(int numWarmup)
            throws InterruptedException

Throws:

InterruptedException

call

public Void call()
          throws Exception

Specified by:

call in interface Callable<Void>

Throws:

Exception