pyflink.datastream.connectors.pulsar.StopCursor

class StopCursor(_j_stop_cursor)

A factory class for users to specify the stop position of a pulsar subscription. Since it would be serialized into split. The implementation for this interface should be well considered. I don’t recommend adding extra internal state for this implementation.

Methods

after_event_time(timestamp)	Stop consuming when message eventTime is greater than the specified timestamp.
after_message_id(message_id)	Stop consuming when the messageId is greater than the specified messageId.
after_publish_time(timestamp)	Stop consuming when message publishTime is greater than the specified timestamp.
at_event_time(timestamp)	Stop consuming when message eventTime is greater than or equals the specified timestamp.
at_message_id(message_id)	Stop consuming when the messageId is equal or greater than the specified messageId.
at_publish_time(timestamp)	Stop consuming when message publishTime is greater than or equals the specified timestamp.
default_stop_cursor()
latest()
never()