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

Class TimestampStartCursor

java.lang.Object

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

All Implemented Interfaces:

Serializable, StartCursor

public class TimestampStartCursor
extends Object
implements StartCursor

This cursor would left pulsar start consuming from a specific publish timestamp.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TimestampStartCursor(long timestamp, boolean inclusive)

Method Summary

Modifier and Type	Method and Description
CursorPosition	position(String topic, int partitionId)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.connector.pulsar.source.enumerator.cursor.StartCursor

defaultStartCursor, earliest, fromMessageId, fromMessageId, fromMessageTime, fromPublishTime, latest

Constructor Detail

TimestampStartCursor

public TimestampStartCursor(long timestamp,
                            boolean inclusive)

Method Detail

position

public CursorPosition position(String topic,
                               int partitionId)

Specified by:

position in interface StartCursor