alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-7698 Add instance method for load

Browse Source
This commit is contained in:
twthorn 2024-04-03 12:36:52 -05:00 committed by Jiri Pechanec
parent 46ee422b53
commit 0131401a19
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
debezium-core/src/main/java/io/debezium/pipeline/txmetadata/TransactionContext.java
View File

@ -57,6 +57,15 @@ public Map<String, Object> store(Map<String, Object> offset) {
return offset;
}
/**
* Instance method to allow for overriding by custom transaction contexts.
* @param offsets Offsets to load
* @return TransactionContext instance with loaded offsets
*/
public TransactionContext newTransactionContextFromOffsets(Map<String, ?> offsets) {
return TransactionContext.load(offsets);
}
@SuppressWarnings("unchecked")
public static TransactionContext load(Map<String, ?> offsets) {
final Map<String, Object> o = (Map<String, Object>) offsets;