maksaska commented on code in PR #11612:
URL: https://github.com/apache/ignite/pull/11612#discussion_r1825749155
##########
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java:
##########
@@ -183,6 +185,29 @@ public class CdcMain implements Runnable {
private static final IgniteBiPredicate<WALRecord.RecordType, WALPointer>
ACTIVE_RECS =
(type, ptr) -> type == DATA_RECORD_V2 || type == CDC_DATA_RECORD;
+ /** Histogram buckets for duration wal processing in nanoseconds. */
+ public static final long[] HISTOGRAM_BUCKETS = new long[] {
+ NANOSECONDS.convert(1, MILLISECONDS),
+ NANOSECONDS.convert(10, MILLISECONDS),
+ NANOSECONDS.convert(100, MILLISECONDS),
+ NANOSECONDS.convert(250, MILLISECONDS),
+ NANOSECONDS.convert(1000, MILLISECONDS)
+ };
+
+ /** */
+ public static final String EVENTS_CONSUMPTION_TIME =
"EventsConsumptionTime";
+
+ /** */
+ public static final String EVENTS_CONSUMPTION_TIME_DESC =
Review Comment:
Done!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
