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. We only expose the constructor for end user.

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()
Long	getTimestamp()
CursorPosition.Type	getType()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CursorPosition

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

CursorPosition

public CursorPosition(Long timestamp)

Method Detail

getType

@Internal
public CursorPosition.Type getType()

getMessageId

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

getTimestamp

@Internal
public Long getTimestamp()

toString

public String toString()

Overrides:

toString in class Object