Package | Description |
---|---|
com.yahoo.bullet.pubsub | |
com.yahoo.bullet.pubsub.rest | |
com.yahoo.bullet.querying |
Class and Description |
---|
IdentityPubSubMessageSerDe |
Metadata |
Metadata.Signal |
Publisher |
PubSub
Notation: Partition is a unit of parallelism in the Pub/Sub queue.
|
PubSub.Context
The context determines how the
Publisher and Subscriber returned by PubSub behave. |
PubSubException |
PubSubMessage
The class of messages that can be understood by the PubSub package.
|
PubSubMessageSerDe
This allows you to hook into the
PubSubMessage serialization and deserialization - for instance, if you want
to customize what is done to the message before it is sent to or read in the backend. |
PubSubResponder
This can be extended by any class that needs to respond to a
PubSubMessage . |
Subscriber |
Class and Description |
---|
BufferingSubscriber
This implements a
Subscriber that provides a base subscriber that buffers a fixed number of messages read. |
Publisher |
PubSub
Notation: Partition is a unit of parallelism in the Pub/Sub queue.
|
PubSubException |
PubSubMessage
The class of messages that can be understood by the PubSub package.
|
Subscriber |
Class and Description |
---|
Metadata |
Copyright © 2021. All rights reserved.