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

DBZ-8068 Fix logging for LogMiner streaming metrics

Browse Source
This commit is contained in:
Chris Cranford 2024-07-15 12:35:36 -04:00 committed by Chris Cranford
parent 200d2cabc2
commit bf2d325ddb
1 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSourceMetrics.java
View File

@ -11,6 +11,7 @@
import java.time.Instant;
import java.time.OffsetDateTime;
import java.time.ZoneOffset;
import java.util.Arrays;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
@ -693,8 +694,8 @@ public String toString() {
", commitScn=" + commitScn +
", oldestScn=" + oldestScn +
", oldestScnTime=" + oldestScnTime +
", currentLogFileNames=" + currentLogFileNames +
", redoLogStatuses=" + redoLogStatuses +
", currentLogFileNames=" + Arrays.asList(currentLogFileNames.get()) +
", redoLogStatuses=" + Arrays.asList(redoLogStatuses.get()) +
", databaseZoneOffset=" + databaseZoneOffset +
", batchSize=" + batchSize +
", logSwitchCount=" + logSwitchCount +
@ -721,7 +722,7 @@ public String toString() {
", processGlobalAreaMemory=" + processGlobalAreaMemory +
", abandonedTransactionIds=" + abandonedTransactionIds +
", rolledBackTransactionIds=" + rolledBackTransactionIds +
"} " + super.toString();
"} ";
}
/**
@ -780,6 +781,11 @@ Duration getLast() {
Duration getTotal() {
return total.get();
}
@Override
public String toString() {
return String.format("{min=%s,max=%s,total=%s}", min.get(), max.get(), total.get());
}
}
/**
@ -820,6 +826,11 @@ public long getValue() {
public long getMax() {
return max.get();
}
@Override
public String toString() {
return String.format("{value=%d,max=%d}", value.get(), max.get());
}
}
/**
@ -849,6 +860,11 @@ public void add(T value) {
public Set<T> getAll() {
return this.cache.get().keySet();
}
@Override
public String toString() {
return getAll().toString();
}
}
}