Package io.debezium.relational

Interface RelationalSnapshotChangeEventSource.PooledWork<T extends OffsetContext>

Type Parameters:
T - the offset context type
Enclosing class:
RelationalSnapshotChangeEventSource<P extends Partition,O extends OffsetContext>
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface static interface RelationalSnapshotChangeEventSource.PooledWork<T extends OffsetContext>
Functional interface for snapshot work that uses pooled resources.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    execute(JdbcConnection connection, T offset)
    Execute the work with the provided pooled resources.

  • Method Details

    • execute

      void execute(JdbcConnection connection, T offset) throws Exception
      Execute the work with the provided pooled resources.
      Parameters:
      connection - the JDBC connection from the pool
      offset - the offset context from the pool
      Throws:
      Exception - if an error occurs during execution