org.apache.solr.cloud

Class Overseer

java.lang.Object

org.apache.solr.cloud.Overseer

All Implemented Interfaces:

Closeable, AutoCloseable

public class Overseer
extends Object
implements Closeable

Cluster leader. Responsible node assignments, cluster state file?

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Overseer.FailedOp
static class	Overseer.Stat
static class	Overseer.Stats Used to hold statistics about overseer operations.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ADD_ROUTING_RULE
static String	CREATESHARD
static String	DELETECORE
static String	QUEUE_OPERATION
static String	QUIT
static String	REMOVE_ROUTING_RULE
static String	REMOVECOLLECTION
static String	REMOVESHARD
static String	STATE
static int	STATE_UPDATE_DELAY
static String	UPDATESHARDSTATE

Constructor Summary

Constructors

Constructor and Description
Overseer(ShardHandler shardHandler, UpdateShardHandler updateShardHandler, String adminPath, ZkStateReader reader, ZkController zkController, ConfigSolr config)

Method Summary

Methods

Modifier and Type	Method and Description
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() For tests.
ZkStateReader	getZkStateReader()
static boolean	isLegacy(Map clusterProps)
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

public static final String STATE

See Also:

Constant Field Values

QUIT

public static final String QUIT

See Also:

Constant Field Values

STATE_UPDATE_DELAY

public static final int STATE_UPDATE_DELAY

See Also:

Constant Field Values

CREATESHARD

public static final String CREATESHARD

See Also:

Constant Field Values

UPDATESHARDSTATE

public static final String UPDATESHARDSTATE

See Also:

Constant Field Values

Constructor Detail

Overseer

public Overseer(ShardHandler shardHandler,
        UpdateShardHandler updateShardHandler,
        String adminPath,
        ZkStateReader reader,
        ZkController zkController,
        ConfigSolr config)
         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()

For tests.

Returns:

state updater thread

NOTE: This API is for internal purposes only and might change in incompatible ways in the next release.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getInQueue

public static DistributedQueue getInQueue(SolrZkClient zkClient)

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

isLegacy

public static boolean isLegacy(Map clusterProps)

getZkStateReader

public ZkStateReader getZkStateReader()