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() {
