Package | Description |
---|---|
org.apache.solr.client.solrj.impl |
Concrete implementations of client API classes.
|
org.apache.solr.cloud |
Base classes and utilities for creating and testing Solr Cloud clusters.
|
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 | Class and Description |
---|---|
class |
MockZkStateReader |
Modifier and Type | Method and Description |
---|---|
ZkStateReader |
Overseer.getZkStateReader() |
ZkStateReader |
ZkController.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) |
protected void |
AbstractDistribZkTestBase.waitForRecoveriesToFinish(String collection,
ZkStateReader zkStateReader,
boolean verbose) |
protected void |
AbstractDistribZkTestBase.waitForRecoveriesToFinish(String collection,
ZkStateReader zkStateReader,
boolean verbose,
boolean failOnTimeout) |
protected void |
AbstractDistribZkTestBase.waitForRecoveriesToFinish(String collection,
ZkStateReader zkStateReader,
boolean verbose,
boolean failOnTimeout,
int timeoutSeconds) |
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–2015 The Apache Software Foundation. All rights reserved.