public class OverseerTaskProcessor extends Object implements Runnable, Closeable
OverseerTaskProcessor.OverseerMessageHandlerSelector determines which
OverseerMessageHandler handles specific messages in the
queue.| Modifier and Type | Class and Description |
|---|---|
static interface |
OverseerTaskProcessor.OverseerMessageHandlerSelector
An interface to determine which
OverseerMessageHandler
handles a given message. |
protected class |
OverseerTaskProcessor.Runner |
class |
OverseerTaskProcessor.TaskBatch |
| Modifier and Type | Field and 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 and Description |
|---|
OverseerTaskProcessor(ZkStateReader zkStateReader,
String myId,
Overseer.Stats stats,
OverseerTaskProcessor.OverseerMessageHandlerSelector selector,
OverseerNodePrioritizer prioritizer,
OverseerTaskQueue workQueue,
DistributedMap runningMap,
DistributedMap completedMap,
DistributedMap failureMap) |
| 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,
String path) |
static List<String> |
getSortedOverseerNodeNames(SolrZkClient zk) |
boolean |
isClosed() |
void |
run() |
public static final int MAX_PARALLEL_TASKS
public static final int MAX_BLOCKED_TASKS
public ExecutorService tpe
protected OverseerTaskProcessor.OverseerMessageHandlerSelector selector
public OverseerTaskProcessor(ZkStateReader zkStateReader, String myId, Overseer.Stats stats, OverseerTaskProcessor.OverseerMessageHandlerSelector selector, OverseerNodePrioritizer prioritizer, OverseerTaskQueue workQueue, DistributedMap runningMap, DistributedMap completedMap, DistributedMap failureMap)
public void close()
close in interface Closeableclose in interface AutoCloseablepublic static List<String> getSortedOverseerNodeNames(SolrZkClient zk) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic static List<String> getSortedElectionNodes(SolrZkClient zk, String path) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic static String getLeaderNode(SolrZkClient zkClient) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic static String getLeaderId(SolrZkClient zkClient) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperExceptionInterruptedExceptionprotected org.apache.solr.cloud.Overseer.LeaderStatus amILeader()
public boolean isClosed()
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.