Package | Description |
---|---|
org.apache.solr.client.solrj.impl |
Concrete implementations of client API classes.
|
org.apache.solr.client.solrj.io.stream |
Stream implementations for the Streaming Aggregation API
|
org.apache.solr.common.cloud |
Common Solr Cloud and ZooKeeper related classes reused on both clients & server.
|
Modifier and Type | Method and Description |
---|---|
ZkStateReader |
ZkClientClusterStateProvider.getZkStateReader() |
ZkStateReader |
CloudSolrClient.getZkStateReader() |
Constructor and Description |
---|
ZkClientClusterStateProvider(ZkStateReader zkStateReader) |
Modifier and Type | Method and Description |
---|---|
static Collection<Slice> |
TupleStream.getSlices(String collectionName,
ZkStateReader zkStateReader,
boolean checkAlias) |
static Collection<Slice> |
CloudSolrStream.getSlices(String collectionName,
ZkStateReader zkStateReader,
boolean checkAlias) |
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.
|
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.