public class SubscribeTransform
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.SequencedMessage>>
Modifier and Type | Field and Description |
---|---|
static org.apache.beam.sdk.runners.PTransformOverride |
V1_READ_OVERRIDE |
Constructor and Description |
---|
SubscribeTransform(SubscriberOptions options) |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.SequencedMessage> |
expand(org.apache.beam.sdk.values.PBegin input) |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate
public static final org.apache.beam.sdk.runners.PTransformOverride V1_READ_OVERRIDE
public SubscribeTransform(SubscriberOptions options)
public org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.SequencedMessage> expand(org.apache.beam.sdk.values.PBegin input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<com.google.cloud.pubsublite.proto.SequencedMessage>>