Modifier and Type | Class and Description |
---|---|
protected class |
OverseerCollectionProcessor.Runner |
Modifier and Type | Field and Description |
---|---|
static String |
COLL_CONF |
static String |
COLL_PROP_PREFIX |
static Map<String,Object> |
COLL_PROPS |
static String |
CREATE_NODE_SET |
static String |
CREATE_NODE_SET_EMPTY |
static String |
CREATE_NODE_SET_SHUFFLE |
int |
maxParallelThreads |
static String |
NUM_SLICES |
static String |
ONLY_ACTIVE_NODES |
static String |
ONLY_IF_DOWN |
static String |
REQUESTID |
static String |
ROUTER |
static String |
SHARD_UNIQUE |
static String |
SHARDS_PROP |
ExecutorService |
tpe |
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,
Overseer overseer) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.solr.cloud.Overseer.LeaderStatus |
amILeader() |
void |
close() |
protected void |
crossCheckReplicaStateWithLiveNodes(List<String> liveNodes,
NamedList<Object> collectionProps)
Walks the tree of collection status to verify that any replicas not reporting a "down" status is
on a live node, if any replicas reporting their status as "active" but the node is not live is
marked as "down"; used by CLUSTERSTATUS.
|
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() |
protected SolrResponse |
processMessage(ZkNodeProps message,
String operation) |
void |
run() |
public static final String NUM_SLICES
public static final String CREATE_NODE_SET_SHUFFLE
public static final String CREATE_NODE_SET_EMPTY
public static final String CREATE_NODE_SET
public static final String ROUTER
public static final String SHARDS_PROP
public static final String REQUESTID
public static final String COLL_CONF
public static final String COLL_PROP_PREFIX
public static final String ONLY_IF_DOWN
public static final String SHARD_UNIQUE
public static final String ONLY_ACTIVE_NODES
public int maxParallelThreads
public ExecutorService tpe
public OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandler shardHandler, String adminPath, Overseer.Stats stats, Overseer overseer)
protected OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandlerFactory shardHandlerFactory, String adminPath, Overseer.Stats stats, DistributedQueue workQueue, DistributedMap runningMap, DistributedMap completedMap, DistributedMap failureMap)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public static List<String> getSortedOverseerNodeNames(SolrZkClient zk) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public static List<String> getSortedElectionNodes(SolrZkClient zk, String path) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public static String getLeaderNode(SolrZkClient zkClient) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public static String getLeaderId(SolrZkClient zkClient) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
protected org.apache.solr.cloud.Overseer.LeaderStatus amILeader()
protected SolrResponse processMessage(ZkNodeProps message, String operation)
protected void crossCheckReplicaStateWithLiveNodes(List<String> liveNodes, NamedList<Object> collectionProps)
liveNodes
- List of currently live node names.collectionProps
- Map of collection status information pulled directly from ZooKeeper.public boolean isClosed()
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.