org.apache.solr.cloud
Class Overseer

java.lang.Object
  org.apache.solr.cloud.Overseer

public class Overseer
extends Object

Cluster leader. Responsible node assignments, cluster state file?

Field Summary

static String	ADD_ROUTING_RULE
static String	DELETECORE
static String	QUEUE_OPERATION
static String	REMOVE_ROUTING_RULE
static String	REMOVECOLLECTION
static String	REMOVESHARD
static int	STATE_UPDATE_DELAY

Constructor Summary

Overseer(ShardHandler shardHandler, String adminPath, ZkStateReader reader)

Method Summary

void	close()
static DistributedQueue	getInQueue(SolrZkClient zkClient) Get queue that can be used to send messages to Overseer.
org.apache.solr.cloud.Overseer.OverseerThread	getUpdaterThread()
void	start(String id)

Methods inherited from class java.lang.Object

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

Field Detail

QUEUE_OPERATION

public static final String QUEUE_OPERATION

See Also:

Constant Field Values

DELETECORE

public static final String DELETECORE

See Also:

Constant Field Values

REMOVECOLLECTION

public static final String REMOVECOLLECTION

See Also:

Constant Field Values

REMOVESHARD

public static final String REMOVESHARD

See Also:

Constant Field Values

ADD_ROUTING_RULE

public static final String ADD_ROUTING_RULE

See Also:

Constant Field Values

REMOVE_ROUTING_RULE

public static final String REMOVE_ROUTING_RULE

See Also:

Constant Field Values

STATE_UPDATE_DELAY

public static final int STATE_UPDATE_DELAY

See Also:

Constant Field Values

Constructor Detail

Overseer

public Overseer(ShardHandler shardHandler,
                String adminPath,
                ZkStateReader reader)
         throws org.apache.zookeeper.KeeperException,
                InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

Method Detail

start

public void start(String id)

getUpdaterThread

public org.apache.solr.cloud.Overseer.OverseerThread getUpdaterThread()

close

public void close()

getInQueue

public static DistributedQueue getInQueue(SolrZkClient zkClient)

Get queue that can be used to send messages to Overseer.