org.apache.solr.update

Class PeerSync

java.lang.Object

org.apache.solr.update.PeerSync

public class PeerSync
extends Object

WARNING: This API is experimental and might change in incompatible ways in the next release.

Field Summary

Fields

Modifier and Type	Field and Description
static Comparator<Long>	absComparator
boolean	debug
static org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
PeerSync(SolrCore core, List<String> replicas, int nUpdates)
PeerSync(SolrCore core, List<String> replicas, int nUpdates, boolean cantReachIsSuccess, boolean getNoVersionsIsSuccess)
PeerSync(SolrCore core, List<String> replicas, int nUpdates, boolean cantReachIsSuccess, boolean getNoVersionsIsSuccess, boolean onlyIfActive, boolean doFingerprint)

Method Summary

Methods

Modifier and Type	Method and Description
long	percentile(List<Long> arr, float frac)
void	setStartingVersions(List<Long> startingVersions) optional list of updates we had before possibly receiving new updates
boolean	sync() Returns true if peer sync was successful, meaning that this core may be considered to have the latest updates.
static void	sync(SolrCore core, List<String> replicas, int nUpdates) Requests and applies recent updates from peers

Methods inherited from class java.lang.Object

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

Field Detail

log

public static org.slf4j.Logger log

debug

public boolean debug

absComparator

public static Comparator<Long> absComparator

Constructor Detail

PeerSync

public PeerSync(SolrCore core,
        List<String> replicas,
        int nUpdates)

PeerSync

public PeerSync(SolrCore core,
        List<String> replicas,
        int nUpdates,
        boolean cantReachIsSuccess,
        boolean getNoVersionsIsSuccess)

PeerSync

public PeerSync(SolrCore core,
        List<String> replicas,
        int nUpdates,
        boolean cantReachIsSuccess,
        boolean getNoVersionsIsSuccess,
        boolean onlyIfActive,
        boolean doFingerprint)

Method Detail

setStartingVersions

public void setStartingVersions(List<Long> startingVersions)

optional list of updates we had before possibly receiving new updates

percentile

public long percentile(List<Long> arr,
              float frac)

sync

public boolean 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.

sync

public static void sync(SolrCore core,
        List<String> replicas,
        int nUpdates)

Requests and applies recent updates from peers