Package org.apache.solr.update
Class PeerSync
- java.lang.Object
-
- org.apache.solr.update.PeerSync
-
- All Implemented Interfaces:
SolrMetricProducer
public class PeerSync extends Object implements SolrMetricProducer
This class is useful for performing peer to peer synchronization of recently indexed update commands during recovery process.- WARNING: This API is experimental and might change in incompatible ways in the next release.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
PeerSync.MissedUpdatesFinder
Helper class for doing comparison ourUpdates and other replicas's updates to find the updates that we missedstatic class
PeerSync.MissedUpdatesRequest
Result ofPeerSync.MissedUpdatesFinder
static class
PeerSync.PeerSyncResult
-
Field Summary
Fields Modifier and Type Field Description static Comparator<Long>
absComparator
static String
METRIC_SCOPE
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
initializeMetrics(SolrMetricManager manager, String registry, String tag, String scope)
Initializes metrics specific to this producer.static long
percentile(List<Long> arr, float frac)
PeerSync.PeerSyncResult
sync()
Returns true if peer sync was successful, meaning that this core may be considered to have the latest updates.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.solr.metrics.SolrMetricProducer
initializeMetrics
-
-
-
-
Field Detail
-
absComparator
public static Comparator<Long> absComparator
-
METRIC_SCOPE
public static final String METRIC_SCOPE
- See Also:
- Constant Field Values
-
-
Method Detail
-
initializeMetrics
public void initializeMetrics(SolrMetricManager manager, String registry, String tag, String scope)
Description copied from interface:SolrMetricProducer
Initializes metrics specific to this producer.Note: for back-compatibility this method by default calls
SolrMetricProducer.initializeMetrics(SolrMetricManager, String, String)
.- Specified by:
initializeMetrics
in interfaceSolrMetricProducer
- Parameters:
manager
- an instance ofSolrMetricManager
registry
- registry name where metrics are registeredtag
- symbolic tag that represents a group of related instances that have the same life-cycle. Parent component can use thetag
when callingSolrMetricManager.unregisterGauges(String, String)
to unregister metrics created by this instance of the producer.scope
- scope of the metrics (eg. handler name) to separate metrics of instances of the same component executing in different contexts
-
sync
public PeerSync.PeerSyncResult sync()
Returns true if peer sync was successful, meaning that this core may be considered to have the latest updates. It does not mean that the remote replica is in sync with us.
-
-