@CheckReturnValue @ParametersAreNonnullByDefault

Package org.apache.beam.sdk.io.gcp.pubsublite

Defines transforms for reading and writing from Google Cloud Pub/Sub Lite.

See: Description

Interface Summary

Interface	Description
SerializableStatusFunction<InT,OutT>	A serializable Function that can throw a StatusException.
SerializableSupplier<T>	A serializable Supplier that can throw a StatusException.

Class Summary

Class	Description
CloudPubsubChecks	A class providing a conversion validity check between Cloud Pub/Sub and Pub/Sub Lite message types.
PublisherOptions	Options needed for a Pub/Sub Lite Publisher.
PublisherOptions.Builder
PubsubLiteIO	I/O transforms for reading from Google Pub/Sub Lite.
SubscriberOptions	Options needed for a Pub/Sub Lite Subscriber.
SubscriberOptions.Builder
Uuid	A Uuid storable in a Pub/Sub Lite attribute.
UuidCoder	A coder for a Uuid.
UuidDeduplicationOptions	Options for deduplicating Pub/Sub Lite messages based on the UUID they were published with.
UuidDeduplicationOptions.Builder

Package org.apache.beam.sdk.io.gcp.pubsublite Description

Defines transforms for reading and writing from Google Cloud Pub/Sub Lite.