DBZ-7732 Add connector specific annotation to SnapshotLock and Snapsh…

…otQuery implementations
debezium · Apr 8, 2024 · d5cafc2 · d5cafc2
1 parent 791633f
commit d5cafc2
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/src/main/java/io/debezium/connector/db2/snapshot/lock/ExclusiveSnapshotLock.java b/src/main/java/io/debezium/connector/db2/snapshot/lock/ExclusiveSnapshotLock.java
@@ -9,9 +9,12 @@
 import java.util.Map;
 import java.util.Optional;
 
+import io.debezium.annotation.ConnectorSpecific;
+import io.debezium.connector.db2.Db2Connector;
 import io.debezium.connector.db2.Db2ConnectorConfig;
 import io.debezium.snapshot.spi.SnapshotLock;
 
+@ConnectorSpecific(connector = Db2Connector.class)
 public class ExclusiveSnapshotLock implements SnapshotLock {
 
     @Override

diff --git a/src/main/java/io/debezium/connector/db2/snapshot/lock/NoSnapshotLock.java b/src/main/java/io/debezium/connector/db2/snapshot/lock/NoSnapshotLock.java
@@ -9,9 +9,12 @@
 import java.util.Map;
 import java.util.Optional;
 
+import io.debezium.annotation.ConnectorSpecific;
+import io.debezium.connector.db2.Db2Connector;
 import io.debezium.connector.db2.Db2ConnectorConfig;
 import io.debezium.snapshot.spi.SnapshotLock;
 
+@ConnectorSpecific(connector = Db2Connector.class)
 public class NoSnapshotLock implements SnapshotLock {
 
     @Override

diff --git a/src/main/java/io/debezium/connector/db2/snapshot/query/SelectAllSnapshotQuery.java b/src/main/java/io/debezium/connector/db2/snapshot/query/SelectAllSnapshotQuery.java
@@ -9,9 +9,12 @@
 import java.util.Map;
 import java.util.Optional;
 
+import io.debezium.annotation.ConnectorSpecific;
 import io.debezium.config.CommonConnectorConfig;
+import io.debezium.connector.db2.Db2Connector;
 import io.debezium.snapshot.spi.SnapshotQuery;
 
+@ConnectorSpecific(connector = Db2Connector.class)
 public class SelectAllSnapshotQuery implements SnapshotQuery {
 
     @Override