You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by ng...@apache.org on 2020/08/11 11:13:08 UTC
svn commit: r1880767 -
/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java
Author: ngupta
Date: Tue Aug 11 11:13:07 2020
New Revision: 1880767
URL: http://svn.apache.org/viewvc?rev=1880767&view=rev
Log:
OAK-9167 | Expose last indexed time as a metric
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java
Modified: jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java?rev=1880767&r1=1880766&r2=1880767&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java (original)
+++ jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java Tue Aug 11 11:13:07 2020
@@ -81,6 +81,7 @@ import org.apache.jackrabbit.oak.spi.sta
import org.apache.jackrabbit.oak.spi.state.NodeState;
import org.apache.jackrabbit.oak.spi.state.NodeStateDiff;
import org.apache.jackrabbit.oak.spi.state.NodeStore;
+import org.apache.jackrabbit.oak.stats.CounterStats;
import org.apache.jackrabbit.oak.stats.Counting;
import org.apache.jackrabbit.oak.stats.HistogramStats;
import org.apache.jackrabbit.oak.stats.MeterStats;
@@ -1217,6 +1218,7 @@ public class AsyncIndexUpdate implements
private final MeterStats indexedNodeCountMeter;
private final TimerStats indexerTimer;
private final HistogramStats indexedNodePerCycleHisto;
+ private final CounterStats lastIndexedTime;
private StatisticsProvider statisticsProvider;
private final String[] names = {"Executions", "Nodes"};
@@ -1231,6 +1233,7 @@ public class AsyncIndexUpdate implements
indexerTimer = statsProvider.getTimer(stats("INDEXER_TIME"), StatsOptions.METRICS_ONLY);
indexedNodePerCycleHisto = statsProvider.getHistogram(stats("INDEXER_NODE_COUNT_HISTO"), StatsOptions
.METRICS_ONLY);
+ lastIndexedTime = statsProvider.getCounterStats(stats("LAST_INDEXED_TIME"), StatsOptions.DEFAULT);
try {
consolidatedType = new CompositeType("ConsolidatedStats",
"Consolidated stats", names,
@@ -1246,6 +1249,8 @@ public class AsyncIndexUpdate implements
indexedNodeCountMeter.mark(updates);
indexerTimer.update(timeInMillis, TimeUnit.MILLISECONDS);
indexedNodePerCycleHisto.update(updates);
+ long previousLastIndexedTime = lastIndexedTime.getCount();
+ lastIndexedTime.inc(System.currentTimeMillis() - previousLastIndexedTime);
}
public Counting getExecutionCounter() {