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

Transforms for reading and writing from Apache Pulsar.

See: Description

Class Summary

Class	Description
PulsarIO
PulsarIO.Read
PulsarIO.Write
PulsarMessage	Class representing a Pulsar Message record.
PulsarMessageCoder
PulsarSourceDescriptor
ReadFromPulsarDoFn
WriteToPulsarDoFn

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

Transforms for reading and writing from Apache Pulsar.