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.cloud.overseer |
Classes for updating cluster state in SolrCloud mode.
|
org.apache.solr.common.cloud |
Common Solr Cloud and ZooKeeper related classes reused on both clients & server.
|
org.apache.solr.handler.admin |
SolrRequestHandler implementations for powering he Solr Admin UI |
org.apache.solr.handler.component |
SearchComponent implementations for
use in SearchHandler |
org.apache.solr.update |
APIs and classes for managing index updates
|
Modifier and Type | Method and Description |
---|---|
ZkStateReader |
CloudSolrClient.getZkStateReader() |
Modifier and Type | Class and Description |
---|---|
class |
MockZkStateReader |
Modifier and Type | Method and Description |
---|---|
ZkStateReader |
ZkController.getZkStateReader() |
ZkStateReader |
Overseer.getZkStateReader() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractDistribZkTestBase.assertAllActive(String collection,
ZkStateReader zkStateReader) |
protected void |
AbstractFullDistribZkTestBase.waitForCollection(ZkStateReader reader,
String collection,
int slices) |
static void |
AbstractDistribZkTestBase.waitForCollectionToDisappear(String collection,
ZkStateReader zkStateReader,
boolean verbose,
boolean failOnTimeout,
int timeoutSeconds) |
protected void |
AbstractDistribZkTestBase.waitForRecoveriesToFinish(String collection,
ZkStateReader zkStateReader,
boolean verbose) |
protected void |
AbstractDistribZkTestBase.waitForRecoveriesToFinish(String collection,
ZkStateReader zkStateReader,
boolean verbose,
boolean failOnTimeout) |
static void |
AbstractDistribZkTestBase.waitForRecoveriesToFinish(String collection,
ZkStateReader zkStateReader,
boolean verbose,
boolean failOnTimeout,
int timeoutSeconds) |
Modifier and Type | Field and Description |
---|---|
protected ZkStateReader |
ZkStateWriter.reader |
protected ZkStateReader |
ClusterStateMutator.zkStateReader |
protected ZkStateReader |
SliceMutator.zkStateReader |
protected ZkStateReader |
CollectionMutator.zkStateReader |
protected ZkStateReader |
ReplicaMutator.zkStateReader |
Constructor and Description |
---|
ClusterStateMutator(ZkStateReader zkStateReader) |
CollectionMutator(ZkStateReader zkStateReader) |
ReplicaMutator(ZkStateReader reader) |
SliceMutator(ZkStateReader zkStateReader) |
ZkStateWriter(ZkStateReader zkStateReader,
Overseer.Stats stats) |
Modifier and Type | Method and Description |
---|---|
static DocCollection |
ZkStateReader.getCollectionLive(ZkStateReader zkStateReader,
String coll) |
static int |
ClusterStateUtil.getLiveAndActiveReplicaCount(ZkStateReader zkStateReader,
String collection) |
static boolean |
ClusterStateUtil.isAutoAddReplicas(ZkStateReader reader,
String collection) |
static boolean |
ClusterStateUtil.waitForAllActiveAndLiveReplicas(ZkStateReader zkStateReader,
int timeoutInMs)
Wait to see *all* cores live and active.
|
static boolean |
ClusterStateUtil.waitForAllActiveAndLiveReplicas(ZkStateReader zkStateReader,
String collection,
int timeoutInMs)
Wait to see *all* cores live and active.
|
static boolean |
ClusterStateUtil.waitForAllReplicasNotLive(ZkStateReader zkStateReader,
int timeoutInMs) |
static boolean |
ClusterStateUtil.waitForAllReplicasNotLive(ZkStateReader zkStateReader,
String collection,
int timeoutInMs) |
static boolean |
ClusterStateUtil.waitForLiveAndActiveReplicaCount(ZkStateReader zkStateReader,
String collection,
int replicaCount,
int timeoutInMs) |
static boolean |
ClusterStateUtil.waitToSeeLiveReplica(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 |
---|
ClusterStatus(ZkStateReader zkStateReader,
ZkNodeProps props) |
Modifier and Type | Method and Description |
---|---|
TrackingShardHandlerFactory.ShardRequestAndParams |
TrackingShardHandlerFactory.RequestTrackingQueue.getShardRequestByPurpose(ZkStateReader zkStateReader,
String collectionName,
String shardId,
int purpose)
Retrieve request recorded by this queue which were sent to given collection, shard and purpose
|
List<TrackingShardHandlerFactory.ShardRequestAndParams> |
TrackingShardHandlerFactory.RequestTrackingQueue.getShardRequests(ZkStateReader zkStateReader,
String collectionName,
String shardId)
Retrieve all requests recorded by this queue which were sent to given collection and shard
|
Constructor and Description |
---|
RetryNode(ZkCoreNodeProps nodeProps,
ZkStateReader zkStateReader,
String collection,
String shardId) |
Copyright © 2000–2015 The Apache Software Foundation. All rights reserved.