Package org.apache.beam.sdk.io.pulsar

package org.apache.beam.sdk.io.pulsar

Transforms for reading and writing from Apache Pulsar. Support is currently experimental, and there may be bugs and performance issues; see https://github.com/apache/beam/issues/31078 for more info, and comment in that issue if you run into issues with this IO.

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

Classes

Class	Description
NaiveReadFromPulsarDoFn<T>	DoFn for reading from Apache Pulsar based on Pulsar Reader from the start message id.
PulsarIO	IO connector for reading and writing from Apache Pulsar.
PulsarIO.Read<T>
PulsarIO.Write
PulsarMessage	Class representing a Pulsar Message record.
PulsarSourceDescriptor
WriteToPulsarDoFn	DoFn for writing to Apache Pulsar.