Class NoLockingSupport

java.lang.Object
io.debezium.snapshot.lock.NoLockingSupport
All Implemented Interfaces:
Service, SnapshotLock, io.debezium.spi.common.Configurable

public class NoLockingSupport extends Object implements SnapshotLock
  • Field Details

  • Constructor Details

    • NoLockingSupport

      public NoLockingSupport()
  • Method Details

    • name

      public String name()
      Specified by:
      name in interface SnapshotLock
      Returns:
      the name of the snapshot lock.
    • configure

      public void configure(Map<String,?> properties)
      Specified by:
      configure in interface io.debezium.spi.common.Configurable
    • tableLockingStatement

      public Optional<String> tableLockingStatement(Duration lockTimeout, String tableId)
      Description copied from interface: SnapshotLock
      Returns a SQL statement for locking the given tables during snapshotting, if required by the specific snapshotter implementation.
      Specified by:
      tableLockingStatement in interface SnapshotLock