public class Overseer extends Object implements Closeable
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.
|
Modifier and Type | Field and Description |
---|---|
static int |
NUM_RESPONSES_TO_STORE |
static String |
OVERSEER_ELECT |
static String |
QUEUE_OPERATION |
static int |
STATE_UPDATE_BATCH_SIZE |
static int |
STATE_UPDATE_DELAY |
Constructor and Description |
---|
Overseer(ShardHandler shardHandler,
UpdateShardHandler updateShardHandler,
String adminPath,
ZkStateReader reader,
ZkController zkController,
CloudConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static ZkDistributedQueue |
getStateUpdateQueue(SolrZkClient zkClient)
Get queue that can be used to send messages to Overseer.
|
Overseer.Stats |
getStats() |
org.apache.solr.cloud.Overseer.OverseerThread |
getUpdaterThread()
For tests.
|
ZkStateReader |
getZkStateReader() |
static boolean |
isLegacy(ZkStateReader stateReader) |
void |
start(String id) |
public static final String QUEUE_OPERATION
public static final int STATE_UPDATE_DELAY
public static final int STATE_UPDATE_BATCH_SIZE
public static final int NUM_RESPONSES_TO_STORE
public static final String OVERSEER_ELECT
public Overseer(ShardHandler shardHandler, UpdateShardHandler updateShardHandler, String adminPath, ZkStateReader reader, ZkController zkController, CloudConfig config) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public void start(String id)
public Overseer.Stats getStats()
public org.apache.solr.cloud.Overseer.OverseerThread getUpdaterThread()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public static ZkDistributedQueue getStateUpdateQueue(SolrZkClient zkClient)
Any and all modifications to the cluster state must be sent to
the overseer via this queue. The complete list of overseer actions
supported by this queue are documented inside the OverseerAction
enum.
Performance statistics on the returned queue
are not tracked by the Overseer Stats API,
see CollectionParams.CollectionAction.OVERSEERSTATUS
.
Therefore, this method should be used only by clients for writing to the overseer queue.
This method will create the /overseer znode in ZooKeeper if it does not exist already.
zkClient
- the SolrZkClient
to be used for reading/writing to the queueZkDistributedQueue
objectpublic static boolean isLegacy(ZkStateReader stateReader)
public ZkStateReader getZkStateReader()
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.