See: Description
| Interface | Description |
|---|---|
| PubsubClient.PubsubClientFactory |
Factory for creating clients.
|
| PubsubOptions |
Properties that can be set when using Google Cloud Pub/Sub with the Apache Beam SDK.
|
| PubsubTestClient.PubsubTestClientFactory |
Closing the factory will validate all expected messages were processed.
|
| TestPubsub.PollingAssertion | |
| TestPubsubOptions |
| Class | Description |
|---|---|
| PubsubClient |
An (abstract) helper class for talking to Pubsub via an underlying transport.
|
| PubsubClient.OutgoingMessage |
A message to be sent to Pubsub.
|
| PubsubClient.ProjectPath |
Path representing a cloud project id.
|
| PubsubClient.SubscriptionPath |
Path representing a Pubsub subscription.
|
| PubsubClient.TopicPath |
Path representing a Pubsub topic.
|
| PubsubCoderProviderRegistrar |
A
CoderProviderRegistrar for standard types used with PubsubIO. |
| PubsubGrpcClient |
A helper class for talking to Pubsub via grpc.
|
| PubsubIO |
Read and Write
PTransforms for Cloud Pub/Sub streams. |
| PubsubIO.PubsubSubscription |
Class representing a Cloud Pub/Sub Subscription.
|
| PubsubIO.PubsubTopic |
Class representing a Cloud Pub/Sub Topic.
|
| PubsubIO.Read<T> |
Implementation of
PubsubIO.read(). |
| PubsubIO.Read.External |
Exposes
PubSubIO.Read as an external transform for cross-language usage. |
| PubsubIO.Read.External.Configuration |
Parameters class to expose the transform to an external SDK.
|
| PubsubIO.Write<T> |
Implementation of
PubsubIO.write(). |
| PubsubIO.Write.External |
Exposes
PubSubIO.Write as an external transform for cross-language usage. |
| PubsubIO.Write.External.Configuration |
Parameters class to expose the transform to an external SDK.
|
| PubsubJsonClient |
A Pubsub client using JSON transport.
|
| PubsubMessage |
Class representing a Pub/Sub message.
|
| PubsubMessagePayloadOnlyCoder |
A coder for PubsubMessage treating the raw bytes being decoded as the message's payload.
|
| PubsubMessageWithAttributesAndMessageIdCoder |
A coder for PubsubMessage including attributes and the message id from the PubSub server.
|
| PubsubMessageWithAttributesCoder |
A coder for PubsubMessage including attributes.
|
| PubsubMessageWithMessageIdCoder |
A coder for PubsubMessage treating the raw bytes being decoded as the message's payload, with the
message id from the PubSub server.
|
| PubsubTestClient |
A (partial) implementation of
PubsubClient for use by unit tests. |
| PubsubUnboundedSink |
A PTransform which streams messages to Pubsub.
|
| PubsubUnboundedSource |
Users should use
PubsubIO.read() instead. |
| TestPubsub |
Test rule which creates a new topic and subscription with randomized names and exposes the APIs
to work with them.
|
| TestPubsubSignal |
Test rule which observes elements of the
PCollection and checks whether they match the
success criteria. |
PubsubIO