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 |
boolean |
debug
|
static org.slf4j.Logger |
log
|
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 |
log
public static org.slf4j.Logger log
debug
public boolean debug
PeerSync
public PeerSync(SolrCore core,
List<String> replicas,
int nUpdates)
PeerSync
public PeerSync(SolrCore core,
List<String> replicas,
int nUpdates,
boolean cantReachIsSuccess,
boolean getNoVersionsIsSuccess)
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.