pyflink.datastream.connectors.StartCursor#
- class StartCursor(_j_start_cursor)[source]#
A factory class for users to specify the start 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.
This class would be used only for SubscriptionType.Exclusive and SubscriptionType.Failover.
Methods
default_start_cursor
()earliest
()from_message_time
(timestamp)latest
()