org.apache.solr.cloud

Class ReplicateFromLeader

java.lang.Object

org.apache.solr.cloud.ReplicateFromLeader

public class ReplicateFromLeader
extends Object

Constructor Summary

Constructors

Constructor and Description
ReplicateFromLeader(CoreContainer cc, String coreName)

Method Summary

Modifier and Type	Method and Description
static String	getCommitVersion(SolrCore solrCore)
void	startReplication(boolean switchTransactionLog) Start a replication handler thread that will periodically pull indices from the shard leader
void	stopReplication()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicateFromLeader

public ReplicateFromLeader(CoreContainer cc,
                           String coreName)

Method Detail

startReplication

public void startReplication(boolean switchTransactionLog)

Start a replication handler thread that will periodically pull indices from the shard leader

This is separate from the ReplicationHandler that listens at /replication, used for recovery and leader actions. It is simpler to discard the entire polling ReplicationHandler rather then worrying about disabling polling and correctly setting all of the leader bits if we need to reset.

TODO: It may be cleaner to extract the polling logic use that directly instead of creating what might be a fairly heavyweight instance here.

Parameters:

switchTransactionLog - if true, ReplicationHandler will rotate the transaction log once the replication is done

getCommitVersion

public static String getCommitVersion(SolrCore solrCore)

stopReplication

public void stopReplication()