Package org.apache.solr.cloud

Class OverseerTaskProcessor

java.lang.Object

org.apache.solr.cloud.OverseerTaskProcessor

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

Direct Known Subclasses:

OverseerCollectionConfigSetProcessor

public class OverseerTaskProcessor
extends Object
implements Runnable, Closeable

A generic processor run in the Overseer, used for handling items added to a distributed work queue. Has support for handling exclusive tasks (i.e. tasks that should not run in parallel with each other).

An OverseerTaskProcessor.OverseerMessageHandlerSelector determines which OverseerMessageHandler handles specific messages in the queue.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	OverseerTaskProcessor.OverseerMessageHandlerSelector	An interface to determine which OverseerMessageHandler handles a given message.
protected class	OverseerTaskProcessor.Runner

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_BLOCKED_TASKS
static int	MAX_PARALLEL_TASKS	Maximum number of overseer collection operations which can be executed concurrently
protected OverseerTaskProcessor.OverseerMessageHandlerSelector	selector
ExecutorService	tpe

Constructor Summary

Constructors

Constructor	Description
OverseerTaskProcessor(org.apache.solr.common.cloud.ZkStateReader zkStateReader, String myId, Stats stats, OverseerTaskProcessor.OverseerMessageHandlerSelector selector, OverseerNodePrioritizer prioritizer, OverseerTaskQueue workQueue, DistributedMap runningMap, DistributedMap completedMap, DistributedMap failureMap, SolrMetricsContext solrMetricsContext)

Method Summary

Modifier and Type	Method	Description
protected org.apache.solr.cloud.Overseer.LeaderStatus	amILeader()
void	close()
protected OverseerTaskProcessor.Runner	createRunner(OverseerMessageHandler messageHandler, org.apache.solr.common.cloud.ZkNodeProps message, String operation, OverseerTaskQueue.QueueEvent head, OverseerMessageHandler.Lock lock)	Create a runner instance to execute a single task.
static String	getLeaderId(org.apache.solr.common.cloud.SolrZkClient zkClient)
static String	getLeaderNode(org.apache.solr.common.cloud.SolrZkClient zkClient)
static List<String>	getSortedElectionNodes(org.apache.solr.common.cloud.SolrZkClient zk, String path)
static List<String>	getSortedOverseerNodeNames(org.apache.solr.common.cloud.SolrZkClient zk)
boolean	isClosed()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_PARALLEL_TASKS

public static final int MAX_PARALLEL_TASKS

Maximum number of overseer collection operations which can be executed concurrently

See Also:

Constant Field Values

MAX_BLOCKED_TASKS

public static final int MAX_BLOCKED_TASKS

See Also:

Constant Field Values

tpe

public ExecutorService tpe

selector

protected OverseerTaskProcessor.OverseerMessageHandlerSelector selector

Constructor Detail

OverseerTaskProcessor

public OverseerTaskProcessor(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                             String myId,
                             Stats stats,
                             OverseerTaskProcessor.OverseerMessageHandlerSelector selector,
                             OverseerNodePrioritizer prioritizer,
                             OverseerTaskQueue workQueue,
                             DistributedMap runningMap,
                             DistributedMap completedMap,
                             DistributedMap failureMap,
                             SolrMetricsContext solrMetricsContext)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getSortedOverseerNodeNames

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

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getSortedElectionNodes

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

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getLeaderNode

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

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getLeaderId

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

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

amILeader

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

isClosed

public boolean isClosed()

createRunner

protected OverseerTaskProcessor.Runner createRunner(OverseerMessageHandler messageHandler,
                                                    org.apache.solr.common.cloud.ZkNodeProps message,
                                                    String operation,
                                                    OverseerTaskQueue.QueueEvent head,
                                                    OverseerMessageHandler.Lock lock)

Create a runner instance to execute a single task. This method mosty exists to provide an extension point for tests.