@CheckReturnValue @ParametersAreNonnullByDefault
See: Description
| Interface | Description |
|---|---|
| ManagedFactory<T extends java.lang.AutoCloseable> |
A ManagedFactory produces instances and tears down any produced instances when it is itself
closed.
|
| Class | Description |
|---|---|
| AddUuidsTransform |
A transform to add UUIDs to each message to be written to Pub/Sub Lite.
|
| BlockingCommitterImpl | |
| CheckpointMarkImpl | |
| DlqProvider | |
| ExternalTransformRegistrarImpl | |
| ManagedFactoryImpl<T extends java.lang.AutoCloseable> | |
| OffsetByteRangeCoder | |
| ProtoFromBytes<T extends com.google.protobuf.Message> | |
| ProtoToBytes<T extends com.google.protobuf.Message> | |
| PubsubLiteSink |
A sink which publishes messages to Pub/Sub Lite.
|
| SubscribeTransform | |
| SubscriptionPartition | |
| SubscriptionPartitionCoder | |
| TrackerWithProgress | |
| UnboundedReaderImpl | |
| UnboundedSourceImpl | |
| Uuid |
A Uuid storable in a Pub/Sub Lite attribute.
|
| UuidCoder |
A coder for a Uuid.
|
| UuidDeduplicationTransform |
A transform for deduplicating Pub/Sub Lite messages based on the UUID they were published with.
|