org.apache.solr.cloud

Class OverseerAutoReplicaFailoverThread

java.lang.Object

org.apache.solr.cloud.OverseerAutoReplicaFailoverThread

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class OverseerAutoReplicaFailoverThread
extends Object
implements Runnable, Closeable

In this simple initial implementation we are limited in how quickly we detect a failure by a worst case of roughly zk session timeout + WAIT_AFTER_EXPIRATION_SECONDS + WORK_LOOP_DELAY_MS and best case of roughly zk session timeout + WAIT_AFTER_EXPIRATION_SECONDS. Also, consider the time to create the SolrCore, do any recovery necessary, and warm up the readers. NOTE: this will only work with collections created via the collections api because they will have defined replicationFactor and maxShardsPerNode.

WARNING: This API is experimental and might change in incompatible ways in the next release.

Constructor Summary

Constructors

Constructor and Description
OverseerAutoReplicaFailoverThread(CloudConfig config, ZkStateReader zkStateReader, UpdateShardHandler updateShardHandler)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isClosed()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

OverseerAutoReplicaFailoverThread

public OverseerAutoReplicaFailoverThread(CloudConfig config,
                                         ZkStateReader zkStateReader,
                                         UpdateShardHandler updateShardHandler)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

isClosed

public boolean isClosed()