| 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–2021 The Apache Software Foundation. All rights reserved.