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

Class CloudPubsubChecks

java.lang.Object

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

public final class CloudPubsubChecks
extends java.lang.Object

A class providing a conversion validity check between Cloud Pub/Sub and Pub/Sub Lite message types.

Method Summary

Modifier and Type	Method and Description
static PTransform<PCollection<? extends com.google.cloud.pubsublite.proto.PubSubMessage>,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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

ensureUsableAsCloudPubsub

public static PTransform<PCollection<? extends com.google.cloud.pubsublite.proto.PubSubMessage>,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.

Will fail the pipeline if a message has multiple attributes per key.