pyflink.datastream.connectors.StopCursor#
- class StopCursor(_j_stop_cursor)[source]#
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
at_event_time
(timestamp)default_stop_cursor
()latest
()never
()