org.apache.solr.cloud

Class OverseerCollectionProcessor

java.lang.Object

org.apache.solr.cloud.OverseerCollectionProcessor

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class OverseerCollectionProcessor
extends Object
implements Runnable, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	OverseerCollectionProcessor.Runner

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASYNC
static String	COLL_CONF
static String	COLL_PROP_PREFIX
static Map<String,Object>	COLL_PROPS
static String	CREATE_NODE_SET
static String	CREATEALIAS
static String	CREATECOLLECTION
static String	CREATESHARD
static String	DELETEALIAS
static String	DELETECOLLECTION
static String	DELETEREPLICA
static String	DELETESHARD
static Set<String>	KNOWN_CLUSTER_PROPS
static String	MAX_SHARDS_PER_NODE
int	maxParallelThreads
static String	MIGRATE
static String	NUM_SLICES
static String	RELOADCOLLECTION
static String	REPLICATION_FACTOR
static String	REQUESTID
static String	ROUTER
static String	SHARDS_PROP
static String	SPLITSHARD
ExecutorService	tpe

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandlerFactory shardHandlerFactory, String adminPath, Overseer.Stats stats, DistributedQueue workQueue, DistributedMap runningMap, DistributedMap completedMap, DistributedMap failureMap)
	OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandler shardHandler, String adminPath, Overseer.Stats stats)

Method Summary

Methods

Modifier and Type	Method and Description
protected org.apache.solr.cloud.Overseer.LeaderStatus	amILeader()
void	close()
static String	getLeaderId(SolrZkClient zkClient)
static String	getLeaderNode(SolrZkClient zkClient)
static List<String>	getSortedElectionNodes(SolrZkClient zk)
static List<String>	getSortedOverseerNodeNames(SolrZkClient zk)
boolean	isClosed()
protected SolrResponse	processMessage(ZkNodeProps message, String operation)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

NUM_SLICES

public static final String NUM_SLICES

See Also:

Constant Field Values

REPLICATION_FACTOR

public static final String REPLICATION_FACTOR

See Also:

Constant Field Values

MAX_SHARDS_PER_NODE

public static final String MAX_SHARDS_PER_NODE

See Also:

Constant Field Values

CREATE_NODE_SET

public static final String CREATE_NODE_SET

See Also:

Constant Field Values

DELETECOLLECTION

public static final String DELETECOLLECTION

See Also:

Constant Field Values

CREATECOLLECTION

public static final String CREATECOLLECTION

See Also:

Constant Field Values

RELOADCOLLECTION

public static final String RELOADCOLLECTION

See Also:

Constant Field Values

CREATEALIAS

public static final String CREATEALIAS

See Also:

Constant Field Values

DELETEALIAS

public static final String DELETEALIAS

See Also:

Constant Field Values

SPLITSHARD

public static final String SPLITSHARD

See Also:

Constant Field Values

DELETESHARD

public static final String DELETESHARD

See Also:

Constant Field Values

ROUTER

public static final String ROUTER

See Also:

Constant Field Values

SHARDS_PROP

public static final String SHARDS_PROP

See Also:

Constant Field Values

ASYNC

public static final String ASYNC

See Also:

Constant Field Values

CREATESHARD

public static final String CREATESHARD

See Also:

Constant Field Values

DELETEREPLICA

public static final String DELETEREPLICA

See Also:

Constant Field Values

MIGRATE

public static final String MIGRATE

See Also:

Constant Field Values

REQUESTID

public static final String REQUESTID

See Also:

Constant Field Values

COLL_CONF

public static final String COLL_CONF

See Also:

Constant Field Values

COLL_PROP_PREFIX

public static final String COLL_PROP_PREFIX

See Also:

Constant Field Values

maxParallelThreads

public int maxParallelThreads

KNOWN_CLUSTER_PROPS

public static final Set<String> KNOWN_CLUSTER_PROPS

COLL_PROPS

public static final Map<String,Object> COLL_PROPS

tpe

public ExecutorService tpe

Constructor Detail

OverseerCollectionProcessor

public OverseerCollectionProcessor(ZkStateReader zkStateReader,
                           String myId,
                           ShardHandler shardHandler,
                           String adminPath,
                           Overseer.Stats stats)

OverseerCollectionProcessor

protected OverseerCollectionProcessor(ZkStateReader zkStateReader,
                           String myId,
                           ShardHandlerFactory shardHandlerFactory,
                           String adminPath,
                           Overseer.Stats stats,
                           DistributedQueue workQueue,
                           DistributedMap runningMap,
                           DistributedMap completedMap,
                           DistributedMap failureMap)

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

getSortedOverseerNodeNames

public static List<String> getSortedOverseerNodeNames(SolrZkClient zk)
                                               throws org.apache.zookeeper.KeeperException,
                                                      InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getSortedElectionNodes

public static List<String> getSortedElectionNodes(SolrZkClient zk)
                                           throws org.apache.zookeeper.KeeperException,
                                                  InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getLeaderNode

public static String getLeaderNode(SolrZkClient zkClient)
                            throws org.apache.zookeeper.KeeperException,
                                   InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getLeaderId

public static String getLeaderId(SolrZkClient zkClient)
                          throws org.apache.zookeeper.KeeperException,
                                 InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

amILeader

protected org.apache.solr.cloud.Overseer.LeaderStatus amILeader()

processMessage

protected SolrResponse processMessage(ZkNodeProps message,
                          String operation)

isClosed

public boolean isClosed()