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

Class PulsarIO

java.lang.Object

org.apache.beam.sdk.io.pulsar.PulsarIO

public class PulsarIO
extends Object

Class 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PulsarIO.Read
static class	PulsarIO.Write

Method Summary

Modifier and Type	Method	Description
static PulsarIO.Read	read()	Read from Apache Pulsar.
static PulsarIO.Write	write()	Write to Apache Pulsar.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

read

public static PulsarIO.Read read()

Read 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.

write

public static PulsarIO.Write write()

Write to 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.