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 incomplete, and there may be bugs; 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
PulsarIO	Class for reading and writing from Apache Pulsar.
PulsarIO.Read
PulsarIO.Write
PulsarMessage	Class representing a Pulsar Message record.
PulsarMessageCoder
PulsarSourceDescriptor
ReadFromPulsarDoFn	Transform for reading from Apache Pulsar.
WriteToPulsarDoFn	Transform for writing to Apache Pulsar.