public class Overseer extends Object
Modifier and Type | Field and Description |
---|---|
static String |
ADD_ROUTING_RULE |
static String |
DELETECORE |
static String |
QUEUE_OPERATION |
static String |
REMOVE_ROUTING_RULE |
static String |
REMOVECOLLECTION |
static String |
REMOVESHARD |
static int |
STATE_UPDATE_DELAY |
Constructor and Description |
---|
Overseer(ShardHandler shardHandler,
String adminPath,
ZkStateReader reader) |
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() |
void |
start(String id) |
public static final String QUEUE_OPERATION
public static final String DELETECORE
public static final String REMOVECOLLECTION
public static final String REMOVESHARD
public static final String ADD_ROUTING_RULE
public static final String REMOVE_ROUTING_RULE
public static final int STATE_UPDATE_DELAY
public Overseer(ShardHandler shardHandler, String adminPath, ZkStateReader reader) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public void start(String id)
public org.apache.solr.cloud.Overseer.OverseerThread getUpdaterThread()
public void close()
public static DistributedQueue getInQueue(SolrZkClient zkClient)
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.