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	DELETECORE
static String	QUEUE_OPERATION
static String	REMOVECOLLECTION
static String	REMOVESHARD

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.
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

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)

close

public void close()

getInQueue

public static DistributedQueue getInQueue(SolrZkClient zkClient)

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