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

DBZ-8054 Formatting

Browse Source
This commit is contained in:
Jeremy Ford 2024-07-29 21:08:27 -04:00 committed by Chris Cranford
parent 76aa135c0c
commit 41a817828d
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java
View File

@ -1546,7 +1546,7 @@ protected void abandonTransactionOverEventThreshold(T transaction) {
metrics.incrementOversizedTransactionCount(); metrics.incrementOversizedTransactionCount();
} }
//this implementation is different // this implementation is different
@Override @Override
public void abandonTransactions(Duration retention) throws InterruptedException { public void abandonTransactions(Duration retention) throws InterruptedException {
if (!Duration.ZERO.equals(retention)) { if (!Duration.ZERO.equals(retention)) {

10
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractTransactionCachingLogMinerEventProcessor.java
View File

@ -97,7 +97,7 @@ protected boolean isRecentlyProcessed(String transactionId) {
return getProcessedTransactionsCache().containsKey(transactionId); return getProcessedTransactionsCache().containsKey(transactionId);
} }
//from EmbeddedInfinispanLogMinerEventProcessor, impl is different // from EmbeddedInfinispanLogMinerEventProcessor, impl is different
@Override @Override
protected Scn getTransactionCacheMinimumScn() { protected Scn getTransactionCacheMinimumScn() {
return getTransactionCache().streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getValue) return getTransactionCache().streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getValue)
@ -106,20 +106,20 @@ protected Scn getTransactionCacheMinimumScn() {
.orElse(Scn.NULL)); .orElse(Scn.NULL));
} }
//from EmbeddedInfinispanLogMinerEventProcessor, impl is different // from EmbeddedInfinispanLogMinerEventProcessor, impl is different
protected Optional<T> getOldestTransactionInCache() { protected Optional<T> getOldestTransactionInCache() {
return getTransactionCache().streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getValue) return getTransactionCache().streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getValue)
.min(this::oldestTransactionComparison)); .min(this::oldestTransactionComparison));
} }
//from EmbeddedInfinispanLogMinerEventProcessor, impl is different // from EmbeddedInfinispanLogMinerEventProcessor, impl is different
@Override @Override
protected String getFirstActiveTransactionKey() { protected String getFirstActiveTransactionKey() {
return getTransactionCache() return getTransactionCache()
.streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getKey).findFirst()).orElse(null); .streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getKey).findFirst()).orElse(null);
} }
//this impl is different // this impl is different
@Override @Override
protected void removeEventWithRowId(LogMinerEventRow row) { protected void removeEventWithRowId(LogMinerEventRow row) {
// locate the events based solely on XIDUSN and XIDSLT. // locate the events based solely on XIDUSN and XIDSLT.
@ -179,7 +179,7 @@ protected boolean hasSchemaChangeBeenSeen(LogMinerEventRow row) {
return getSchemaChangesCache().containsKey(row.getScn().toString()); return getSchemaChangesCache().containsKey(row.getScn().toString());
} }
//different from AbstractInfinispanLogMinerEventProcessor // different from AbstractInfinispanLogMinerEventProcessor
@Override @Override
protected T getAndRemoveTransactionFromCache(String transactionId) { protected T getAndRemoveTransactionFromCache(String transactionId) {
return getTransactionCache().remove(transactionId); return getTransactionCache().remove(transactionId);