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

…otQuery implementations
debezium · Apr 5, 2024 · 8dbb2bf · 8dbb2bf
1 parent 016a78e
commit 8dbb2bf
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