Package org.apache.beam.sdk.io.gcp.pubsublite.internal
@CheckReturnValue
@ParametersAreNonnullByDefault
package org.apache.beam.sdk.io.gcp.pubsublite.internal
Defines transforms for reading and writing from Google Cloud Pub/Sub Lite.
-
ClassDescriptionA transform to add UUIDs to each message to be written to Pub/Sub Lite.ManagedFactory<T extends AutoCloseable>A ManagedFactory produces instances and tears down any produced instances when it is itself closed.ManagedFactoryImpl<T extends AutoCloseable>ProtoFromBytes<T extends Message>ProtoToBytes<T extends Message>A sink which publishes messages to Pub/Sub Lite.A Uuid storable in a Pub/Sub Lite attribute.A coder for a Uuid.A transform for deduplicating Pub/Sub Lite messages based on the UUID they were published with.