Class PubsubIO.Write.PubsubBoundedWriter

java.lang.Object
org.apache.beam.sdk.transforms.DoFn<PubsubMessage,Void>
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Write.PubsubBoundedWriter
All Implemented Interfaces:
Serializable, HasDisplayData
Enclosing class:
PubsubIO.Write<T>

public class PubsubIO.Write.PubsubBoundedWriter extends DoFn<PubsubMessage,Void>
Writer to Pubsub which batches messages from bounded collections.

Public so can be suppressed by runners.

See Also: