public final class CloudPubsubTransforms
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage>,org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage>> |
ensureUsableAsCloudPubsub()
Ensure that all messages that pass through can be converted to Cloud Pub/Sub messages using the
standard transformation methods in the client library.
|
static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<PubsubMessage>,org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage>> |
fromCloudPubsubMessages()
Transform messages publishable using PubsubIO to their equivalent Pub/Sub Lite publishable
message.
|
static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.SequencedMessage>,org.apache.beam.sdk.values.PCollection<PubsubMessage>> |
toCloudPubsubMessages()
Transform messages read from Pub/Sub Lite to their equivalent Cloud Pub/Sub Message that would
have been read from PubsubIO.
|
public static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage>,org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage>> ensureUsableAsCloudPubsub()
Will fail the pipeline if a message has multiple attributes per key.
public static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.SequencedMessage>,org.apache.beam.sdk.values.PCollection<PubsubMessage>> toCloudPubsubMessages()
Will fail the pipeline if a message has multiple attributes per map key.
public static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<PubsubMessage>,org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage>> fromCloudPubsubMessages()