Package org.apache.jackrabbit.oak.plugins.document.util

Class UpsertMetricUpdater

java.lang.Object

org.apache.jackrabbit.oak.plugins.document.util.UpsertMetricUpdater

public final class UpsertMetricUpdater
extends java.lang.Object

Base class to update the metrics for DocumentStoreStatsCollector.doneCreateOrUpdate(long, Collection, List) for underlying DocumentStore

Users provide instances of MeterStats, TimerStats based on whether throttling is ongoing or not

Constructor Summary

Constructors

Constructor	Description
UpsertMetricUpdater(MeterStats createNodeUpsertMeter, MeterStats createSplitNodeMeter, TimerStats createNodeUpsertTimer)

Method Summary

Modifier and Type	Method	Description
void	update(Collection<? extends Document> collection, long timeTakenNanos, java.util.List<java.lang.String> ids, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, TriStatsConsumer upsertStatsConsumer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UpsertMetricUpdater

public UpsertMetricUpdater(MeterStats createNodeUpsertMeter,
                           MeterStats createSplitNodeMeter,
                           TimerStats createNodeUpsertTimer)

Method Detail

update

public void update(Collection<? extends Document> collection,
                   long timeTakenNanos,
                   java.util.List<java.lang.String> ids,
                   java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated,
                   TriStatsConsumer upsertStatsConsumer)