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)

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

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)