public class PeerSync extends Object
Modifier and Type | Field and Description |
---|---|
boolean |
debug |
static org.slf4j.Logger |
log |
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) |
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 it's peers.
|
static void |
sync(SolrCore core,
List<String> replicas,
int nUpdates)
Requests and applies recent updates from peers
|
public PeerSync(SolrCore core, List<String> replicas, int nUpdates, boolean cantReachIsSuccess, boolean getNoVersionsIsSuccess)
public void setStartingVersions(List<Long> startingVersions)
public boolean sync()
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.