Package | Description |
---|---|
com.yahoo.bullet.pubsub | |
com.yahoo.bullet.pubsub.rest |
Modifier and Type | Field and Description |
---|---|
protected Publisher |
BulletPubSubResponder.publisher |
Modifier and Type | Method and Description |
---|---|
abstract Publisher |
PubSub.getPublisher()
Get a
Publisher instance wired to write to all allocated partitions in the appropriate queue (See
PubSub.context ). |
Modifier and Type | Method and Description |
---|---|
abstract List<Publisher> |
PubSub.getPublishers(int n)
Get a list of n
Publisher instances with the allocated partitions in the appropriate queue
(See PubSub.context ) split as evenly as possible among them. |
Modifier and Type | Class and Description |
---|---|
class |
RESTPublisher |
class |
RESTQueryPublisher |
class |
RESTResultPublisher |
Modifier and Type | Method and Description |
---|---|
Publisher |
RESTPubSub.getPublisher() |
Modifier and Type | Method and Description |
---|---|
List<Publisher> |
RESTPubSub.getPublishers(int n) |
Copyright © 2021. All rights reserved.