Package org.apache.flink.streaming.api.checkpoint

Interface ExternallyInducedSource<T,​CD>

  • Type Parameters:
    T - Type of the elements produced by the source function
    CD - The type of the data stored in the checkpoint by the master that triggers
    All Superinterfaces:
    Function, Serializable, SourceFunction<T>, WithMasterCheckpointHook<CD>
    @Internal
public interface ExternallyInducedSource<T,​CD>
extends SourceFunction<T>, WithMasterCheckpointHook<CD>
    Deprecated.
    This interface is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
    Sources that implement this interface delay checkpoints when receiving a trigger message from the checkpoint coordinator to the point when their input data/events indicate that a checkpoint should be triggered.

    Since sources cannot simply create a new checkpoint on their own, this mechanism always goes together with a hook on the master side. In a typical setup, the hook on the master tells the source system (for example the message queue) to prepare a checkpoint. The exact point when the checkpoint is taken is then controlled by the event stream received from the source, and triggered by the source function (implementing this interface) in Flink when seeing the relevant events.

    • Method Detail

      • setCheckpointTrigger

        void setCheckpointTrigger​(ExternallyInducedSource.CheckpointTrigger checkpointTrigger)
        Deprecated.
        Sets the checkpoint trigger through which the source can trigger the checkpoint.
        Parameters:
        checkpointTrigger - The checkpoint trigger to set