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

Class PulsarSourceDescriptor

java.lang.Object

org.apache.beam.sdk.io.pulsar.PulsarSourceDescriptor

All Implemented Interfaces:

Serializable

@DefaultSchema(AutoValueSchema.class)
public abstract class PulsarSourceDescriptor
extends Object
implements Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PulsarSourceDescriptor()

Method Summary

Modifier and Type	Method	Description
static PulsarSourceDescriptor	of(String topic, Long startOffsetTimestamp, Long endOffsetTimestamp, org.apache.pulsar.client.api.MessageId endMessageId, String clientUrl, String adminUrl)

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarSourceDescriptor

public PulsarSourceDescriptor()

Method Details

of

public static PulsarSourceDescriptor of(String topic,
 Long startOffsetTimestamp,
 Long endOffsetTimestamp,
 org.apache.pulsar.client.api.MessageId endMessageId,
 String clientUrl,
 String adminUrl)