public class BenchmarkSubscriber extends BenchmarkWorker implements Callable<Void>
Constructor and Description |
---|
BenchmarkSubscriber(int numTopics,
int numMessages,
int numRegions,
int startTopicLabel,
int partitionIndex,
int numPartitions,
Subscriber subscriber,
com.google.protobuf.ByteString subId) |
public BenchmarkSubscriber(int numTopics, int numMessages, int numRegions, int startTopicLabel, int partitionIndex, int numPartitions, Subscriber subscriber, com.google.protobuf.ByteString subId)
public void warmup(int numWarmup) throws InterruptedException
InterruptedException
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.