Package | Description |
---|---|
org.apache.hedwig.client | |
org.apache.hedwig.client.api | |
org.apache.hedwig.client.benchmark | |
org.apache.hedwig.client.netty |
A Netty based Hedwig client implementation.
|
Modifier and Type | Method and Description |
---|---|
Subscriber |
HedwigClient.getSubscriber() |
Modifier and Type | Method and Description |
---|---|
Subscriber |
Client.getSubscriber()
Retrieve the Subscriber object for the client.
|
Constructor and Description |
---|
BenchmarkPublisher(int numTopics,
int numMessages,
int numRegions,
int startTopicLabel,
int partitionIndex,
int numPartitions,
Publisher publisher,
Subscriber subscriber,
int msgSize,
int nParallel,
int rate) |
BenchmarkSubscriber(int numTopics,
int numMessages,
int numRegions,
int startTopicLabel,
int partitionIndex,
int numPartitions,
Subscriber subscriber,
com.google.protobuf.ByteString subId) |
Modifier and Type | Class and Description |
---|---|
class |
HedwigSubscriber
This is the Hedwig Netty specific implementation of the Subscriber interface.
|
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.