Package | Description |
---|---|
org.apache.solr.client.solrj.cloud.autoscaling |
Common classes for autoscaling parsing filtering nodes and sorting
|
org.apache.solr.client.solrj.impl |
Concrete implementations of client API classes.
|
org.apache.solr.client.solrj.request |
Convenience classes for dealing with various types of Solr requests.
|
org.apache.solr.common.cloud |
Common Solr Cloud and ZooKeeper related classes reused on both clients & server.
|
Modifier and Type | Method and Description |
---|---|
DocCollection |
DelegatingClusterStateProvider.getCollection(String name)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
default DocCollection |
ClusterStateProvider.getCollection(String name) |
protected DocCollection |
BaseCloudSolrClient.getDocCollection(String collection,
Integer expectedVersion) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,? extends LBSolrClient.Req> |
BaseCloudSolrClient.createRoutes(UpdateRequest updateRequest,
ModifiableSolrParams routableParams,
DocCollection col,
DocRouter router,
Map<String,List<String>> urlMap,
String routeField) |
protected Map<String,LBHttpSolrClient.Req> |
CloudSolrClient.createRoutes(UpdateRequest updateRequest,
ModifiableSolrParams routableParams,
DocCollection col,
DocRouter router,
Map<String,List<String>> urlMap,
String idField) |
Modifier and Type | Method and Description |
---|---|
void |
BaseCloudSolrClient.waitForState(String collection,
long wait,
TimeUnit unit,
Predicate<DocCollection> predicate)
Block until a Predicate returns true, or the wait times out
|
Modifier and Type | Method and Description |
---|---|
Map<String,LBHttpSolrClient.Req> |
UpdateRequest.getRoutes(DocRouter router,
DocCollection col,
Map<String,List<String>> urlMap,
ModifiableSolrParams params,
String idField)
Deprecated.
since 8.0, uses
UpdateRequest.getRoutesToCollection(DocRouter, DocCollection, Map, ModifiableSolrParams, String) instead |
Map<String,LBSolrClient.Req> |
UpdateRequest.getRoutesToCollection(DocRouter router,
DocCollection col,
Map<String,List<String>> urlMap,
ModifiableSolrParams params,
String idField) |
Modifier and Type | Method and Description |
---|---|
DocCollection |
DocCollection.copyWith(PerReplicaStates newPerReplicaStates)
Update our state with a state of a
Replica
Used to create a new Collection State when only a replica is updated |
DocCollection |
DocCollection.copyWithSlices(Map<String,Slice> slices)
Use this to make an exact copy of DocCollection with a new set of Slices and every other property as is
|
DocCollection |
ZkStateReader.fetchCollectionState(String coll,
org.apache.zookeeper.Watcher watcher,
String path) |
DocCollection |
ClusterState.CollectionRef.get()
Return the DocCollection, always refetching if lazy.
|
DocCollection |
ClusterState.CollectionRef.get(boolean allowCached)
Return the DocCollection
|
DocCollection |
ZkStateReader.getCollection(String collection) |
DocCollection |
ClusterState.getCollection(String collection)
Get the named DocCollection object, or throw an exception if it doesn't exist.
|
static DocCollection |
ZkStateReader.getCollectionLive(ZkStateReader zkStateReader,
String coll) |
DocCollection |
ClusterState.getCollectionOrNull(String collectionName)
Returns the corresponding
DocCollection object for the given collection name
if such a collection exists. |
DocCollection |
ClusterState.getCollectionOrNull(String collectionName,
boolean allowCached)
Returns the corresponding
DocCollection object for the given collection name
if such a collection exists. |
Modifier and Type | Method and Description |
---|---|
Map<String,DocCollection> |
ClusterState.getCollectionsMap()
Get a map of collection name vs DocCollection objects
Implementation note: This method resolves the collection reference by calling
ClusterState.CollectionRef.get() which can make a call to ZooKeeper. |
Modifier and Type | Method and Description |
---|---|
ClusterState |
ClusterState.copyWith(String collectionName,
DocCollection collection)
Returns a new cluster state object modified with the given collection.
|
Replica |
ZkStateReader.getLeader(Set<String> liveNodes,
DocCollection docCollection,
String shard) |
String |
DocRouter.getRouteField(DocCollection coll) |
DocRouter.Range |
CompositeIdRouter.getSearchRangeSingle(String shardKey,
SolrParams params,
DocCollection collection) |
DocRouter.Range |
DocRouter.getSearchRangeSingle(String shardKey,
SolrParams params,
DocCollection collection)
This method is consulted to determine what search range (the part of the hash ring) should be queried for a request when
an explicit shards parameter was not used.
|
Collection<Slice> |
DocRouter.getSearchSlices(String shardKeys,
SolrParams params,
DocCollection collection)
This method is consulted to determine what slices should be queried for a request when
an explicit shards parameter was not used.
|
Collection<Slice> |
CompositeIdRouter.getSearchSlicesSingle(String shardKey,
SolrParams params,
DocCollection collection) |
abstract Collection<Slice> |
DocRouter.getSearchSlicesSingle(String shardKey,
SolrParams params,
DocCollection collection)
This method is consulted to determine what slices should be queried for a request when
an explicit shards parameter was not used.
|
Collection<Slice> |
ImplicitDocRouter.getSearchSlicesSingle(String shardKey,
SolrParams params,
DocCollection collection) |
Collection<Slice> |
HashBasedRouter.getSearchSlicesSingle(String shardKey,
SolrParams params,
DocCollection collection) |
abstract Slice |
DocRouter.getTargetSlice(String id,
SolrInputDocument sdoc,
String route,
SolrParams params,
DocCollection collection)
Returns the Slice that the document should reside on, or null if there is not enough information
|
Slice |
ImplicitDocRouter.getTargetSlice(String id,
SolrInputDocument sdoc,
String route,
SolrParams params,
DocCollection collection) |
Slice |
HashBasedRouter.getTargetSlice(String id,
SolrInputDocument sdoc,
String route,
SolrParams params,
DocCollection collection) |
protected Slice |
HashBasedRouter.hashToSlice(int hash,
DocCollection collection) |
static boolean |
DocCollection.isFullyActive(Set<String> liveNodes,
DocCollection collectionState,
int expectedShards,
int expectedReplicas)
Check that all replicas in a collection are live
|
abstract boolean |
DocRouter.isTargetSlice(String id,
SolrInputDocument sdoc,
SolrParams params,
String shardId,
DocCollection collection) |
boolean |
ImplicitDocRouter.isTargetSlice(String id,
SolrInputDocument sdoc,
SolrParams params,
String shardId,
DocCollection collection) |
boolean |
HashBasedRouter.isTargetSlice(String id,
SolrInputDocument sdoc,
SolrParams params,
String shardId,
DocCollection collection) |
boolean |
CollectionStatePredicate.matches(Set<String> liveNodes,
DocCollection collectionState)
Check if the set of liveNodes and the collection state matches a required state
|
static PerReplicaStatesOps |
PerReplicaStatesOps.modifyCollection(DocCollection coll,
boolean enable,
PerReplicaStates rs)
Switch a collection from/to perReplicaState=true
|
boolean |
DocCollectionWatcher.onStateChanged(DocCollection collection)
Called when the collection we are registered against has a change of state.
|
boolean |
CollectionStateWatcher.onStateChanged(Set<String> liveNodes,
DocCollection collectionState)
Called when either the collection we are registered against has a change of state or there is a change to the live nodes of our collection.
|
int |
CompositeIdRouter.sliceHash(String id,
SolrInputDocument doc,
SolrParams params,
DocCollection collection) |
int |
HashBasedRouter.sliceHash(String id,
SolrInputDocument sdoc,
SolrParams params,
DocCollection collection) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterState.forEachCollection(Consumer<DocCollection> consumer)
Iterate over collections.
|
void |
ZkStateReader.waitForState(String collection,
long wait,
TimeUnit unit,
Predicate<DocCollection> predicate)
Block until a Predicate returns true, or the wait times out
|
Constructor and Description |
---|
CollectionRef(DocCollection coll) |
Constructor and Description |
---|
ClusterState(Integer znodeVersion,
Set<String> liveNodes,
Map<String,DocCollection> collectionStates)
Use this constr when ClusterState is meant for consumption.
|
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.