Package io.debezium.pipeline.source.spi

Interface ChangeEventSource.ChangeEventSourceContext

All Known Implementing Classes:
ChangeEventSourceCoordinator.ChangeEventSourceContextImpl
Enclosing interface:
ChangeEventSource
public static interface ChangeEventSource.ChangeEventSourceContext

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    isPaused()
    Whether this source is paused.
    boolean
    isRunning()
    Whether this source is running or has been requested to stop.
    void
    resumeStreaming()
    Called to indicate that the snapshot has been completed and that streaming should therefore continue.
    void
    streamingPaused()
    Called by the StreamingChangeEventSource to indicate that the streaming has now been paused, and that no streaming records are being processed anymore.
    void
    waitSnapshotCompletion()
    Wait for the resumeStreaming function to be called, which indicates that a snapshot is done and that streaming should resume.
    void
    waitStreamingPaused()
    Wait for the streamingPaused function to be called.

  • Method Details

    • isPaused

      boolean isPaused()
      Whether this source is paused.

    • isRunning

      boolean isRunning()
      Whether this source is running or has been requested to stop.

    • resumeStreaming

      void resumeStreaming() throws InterruptedException
      Called to indicate that the snapshot has been completed and that streaming should therefore continue.
      Throws:
      InterruptedException

    • waitSnapshotCompletion

      void waitSnapshotCompletion() throws InterruptedException
      Wait for the resumeStreaming function to be called, which indicates that a snapshot is done and that streaming should resume.
      Throws:
      InterruptedException

    • streamingPaused

      void streamingPaused()
      Called by the StreamingChangeEventSource to indicate that the streaming has now been paused, and that no streaming records are being processed anymore.

    • waitStreamingPaused

      void waitStreamingPaused() throws InterruptedException
      Wait for the streamingPaused function to be called.
      Throws:
      InterruptedException