org.apache.solr.update
Class PeerSync

java.lang.Object
  extended by 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
 boolean debug
           
static org.slf4j.Logger log
           
 
Constructor Summary
PeerSync(SolrCore core, List<String> replicas, int nUpdates)
           
PeerSync(SolrCore core, List<String> replicas, int nUpdates, boolean cantReachIsSuccess, boolean getNoVersionsIsSuccess)
           
 
Method Summary
 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 it's 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)
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 it's 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



Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.