public static class PubsubLiteWriteSchemaTransformProvider.SetUuidFromPubSubMessage
extends 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>>
Modifier and Type | Class and Description |
---|---|
static class |
PubsubLiteWriteSchemaTransformProvider.SetUuidFromPubSubMessage.SetUuidFn |
Constructor and Description |
---|
SetUuidFromPubSubMessage(java.lang.String attributeId) |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage> |
expand(org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage> input) |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate
public SetUuidFromPubSubMessage(java.lang.String attributeId)
public org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage> expand(org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.PubSubMessage> input)
expand
in class 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>>