Package | Description |
---|---|
org.apache.solr.client.solrj.impl |
Concrete implementations of client API classes.
|
org.apache.solr.cloud |
Classes for dealing with ZooKeeper when operating in SolrCloud mode.
|
org.apache.solr.common.cloud |
Common Solr Cloud and ZooKeeper related classes reused on both clients & server.
|
org.apache.solr.update |
APIs and classes for managing index updates
|
Modifier and Type | Method and Description |
---|---|
ZkStateReader |
CloudSolrServer.getZkStateReader() |
Modifier and Type | Method and Description |
---|---|
ZkStateReader |
Overseer.getZkStateReader() |
ZkStateReader |
ZkController.getZkStateReader() |
Constructor and Description |
---|
Overseer(ShardHandler shardHandler,
UpdateShardHandler updateShardHandler,
String adminPath,
ZkStateReader reader,
ZkController zkController,
ConfigSolr config) |
OverseerAutoReplicaFailoverThread(ConfigSolr config,
ZkStateReader zkStateReader,
UpdateShardHandler updateShardHandler) |
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) |
Modifier and Type | Method and Description |
---|---|
static boolean |
ClusterStateUtil.isAutoAddReplicas(ZkStateReader reader,
String collection) |
static ClusterState |
ClusterState.load(SolrZkClient zkClient,
Set<String> liveNodes,
ZkStateReader stateReader)
Create ClusterState by reading the current state from zookeeper.
|
static boolean |
ClusterStateUtil.waitForAllActiveAndLive(ZkStateReader zkStateReader,
int timeoutInMs)
Wait to see *all* cores live and active.
|
static boolean |
ClusterStateUtil.waitForAllActiveAndLive(ZkStateReader zkStateReader,
String collection,
int timeoutInMs)
Wait to see *all* cores live and active.
|
static boolean |
ClusterStateUtil.waitForAllNotLive(ZkStateReader zkStateReader,
int timeoutInMs) |
static boolean |
ClusterStateUtil.waitForAllNotLive(ZkStateReader zkStateReader,
String collection,
int timeoutInMs) |
static boolean |
ClusterStateUtil.waitToSeeLive(ZkStateReader zkStateReader,
String collection,
String coreNodeName,
String baseUrl,
int timeoutInMs)
Wait to see an entry in the ClusterState with a specific coreNodeName and
baseUrl.
|
Constructor and Description |
---|
RetryNode(ZkCoreNodeProps nodeProps,
ZkStateReader zkStateReader,
String collection,
String shardId) |
Copyright © 2000–2014 The Apache Software Foundation. All rights reserved.