org.apache.beam.sdk.io.pulsar

Class PulsarIO

java.lang.Object

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

public class PulsarIO
extends java.lang.Object

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and Description
static PulsarIO.Read	read()
static PulsarIO.Write	write()

Methods inherited from class java.lang.Object

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

Method Detail

read

public static PulsarIO.Read read()

write

public static PulsarIO.Write write()