Package io.debezium.pipeline.source.spi

Interface SnapshotProgressListener<P extends Partition>

All Known Subinterfaces:
SnapshotChangeEventSourceMetrics<P>
All Known Implementing Classes:
DefaultSnapshotChangeEventSourceMetrics
public interface SnapshotProgressListener<P extends Partition>
Invoked whenever an important event or change of state happens during the snapshot phase.
Author:
Jiri Pechanec

  • Method Details

    • snapshotStarted

      void snapshotStarted(P partition)

    • snapshotPaused

      void snapshotPaused(P partition)

    • snapshotResumed

      void snapshotResumed(P partition)

    • monitoredDataCollectionsDetermined

      void monitoredDataCollectionsDetermined(P partition, Iterable<? extends io.debezium.spi.schema.DataCollectionId> dataCollectionIds)

    • snapshotCompleted

      void snapshotCompleted(P partition)

    • snapshotAborted

      void snapshotAborted(P partition)

    • snapshotSkipped

      void snapshotSkipped(P partition)

    • dataCollectionSnapshotCompleted

      void dataCollectionSnapshotCompleted(P partition, io.debezium.spi.schema.DataCollectionId dataCollectionId, long numRows)

    • rowsScanned

      void rowsScanned(P partition, TableId tableId, long numRows)

    • currentChunk

      void currentChunk(P partition, String chunkId, Object[] chunkFrom, Object[] chunkTo)

    • currentChunk

      void currentChunk(P partition, String chunkId, Object[] chunkFrom, Object[] chunkTo, Object[] tableTo)

    • chunkProgress

      void chunkProgress(P partition, TableId tableId, long totalChunks, long completedChunks)

    • NO_OP

      static <P extends Partition> SnapshotProgressListener<P> NO_OP()