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

Class PulsarMessage

java.lang.Object

org.apache.beam.sdk.io.pulsar.PulsarMessage

@DefaultSchema(AutoValueSchema.class)
public abstract class PulsarMessage
extends Object

Class representing a Pulsar Message record. Each PulsarMessage contains a single message basic message data and Message record to access directly.

Constructor Summary

Constructors

Constructor	Description
PulsarMessage()

Method Summary

Modifier and Type	Method	Description
static PulsarMessage	create(@Nullable String topicName, long publishTimestamp, @Nullable String key, byte[] value, @Nullable Map<String,String> properties, byte[] messageId)
static PulsarMessage	create(org.apache.pulsar.client.api.Message<byte[]> message)
abstract @Nullable String	getKey()
abstract byte[]	getMessageId()
abstract @Nullable Map<String,String>	getProperties()
abstract long	getPublishTimestamp()
abstract @Nullable String	getTopic()
abstract byte[]	getValue()

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarMessage

public PulsarMessage()

Method Details

getTopic

public abstract @Nullable String getTopic()

getPublishTimestamp

public abstract long getPublishTimestamp()

getKey

public abstract @Nullable String getKey()

getValue

public abstract byte[] getValue()

getProperties

public abstract @Nullable Map<String,String> getProperties()

getMessageId

public abstract byte[] getMessageId()

create

public static PulsarMessage create(@Nullable String topicName,
 long publishTimestamp,
 @Nullable String key,
 byte[] value,
 @Nullable Map<String,String> properties,
 byte[] messageId)

create

public static PulsarMessage create(org.apache.pulsar.client.api.Message<byte[]> message)