org.apache.flink.connector.pulsar.source.enumerator.cursor

Class CursorPosition

java.lang.Object

org.apache.flink.connector.pulsar.source.enumerator.cursor.CursorPosition

All Implemented Interfaces:

Serializable

@PublicEvolving
public final class CursorPosition
extends Object
implements Serializable

The class for defining the start or stop position.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CursorPosition.Type The position type for reader to choose whether timestamp or message id as the start position.

Constructor Summary

Constructors

Constructor and Description
CursorPosition(Long timestamp)
CursorPosition(org.apache.pulsar.client.api.MessageId messageId)

Method Summary

Modifier and Type	Method and Description
org.apache.pulsar.client.api.MessageId	getMessageId()
void	seekPosition(org.apache.pulsar.client.api.Consumer<?> consumer) Pulsar consumer could be subscribed by the position.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CursorPosition

public CursorPosition(@Nullable
                      org.apache.pulsar.client.api.MessageId messageId)

CursorPosition

public CursorPosition(@Nullable
                      Long timestamp)

Method Detail

getMessageId

@VisibleForTesting
public org.apache.pulsar.client.api.MessageId getMessageId()

seekPosition

public void seekPosition(org.apache.pulsar.client.api.Consumer<?> consumer)
                  throws org.apache.pulsar.client.api.PulsarClientException

Pulsar consumer could be subscribed by the position.

Throws:

org.apache.pulsar.client.api.PulsarClientException

toString

public String toString()

Overrides:

toString in class Object