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

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 not be considered to have the latest updates when considering the last N updates between it and its peers.
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

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)

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 not be considered to have the latest updates when considering the last N updates between it and its peers. A commit is not performed.

sync

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

Requests and applies recent updates from peers