Package org.apache.solr.cloud
package org.apache.solr.cloud
Classes for dealing with ZooKeeper when operating in SolrCloud mode.
-
ClassDescriptionWatch for replicas to become
Replica.State.ACTIVE.SolrCloud metadata attached to aCoreDescriptor.Intended for components that should be enabled only one instance per cluster.This class implements a higher level locking abstraction for the Config Set API using lower level read and write locks.This class contains methods dealing with Config Sets and called for Config Set API execution, called from theOverseerConfigSetMessageHandleror fromDistributedCollectionConfigSetCommandRunner.runConfigSetCommand(org.apache.solr.response.SolrQueryResponse, org.apache.solr.common.params.ConfigSetParams.ConfigSetAction, java.util.Map<java.lang.String, java.lang.Object>, long)depending on whether Collection and Config Set APIs are Overseer based or distributed.Class holding the implementation required for tracking asynchronous Collection API (or other) tasks when the Collection API is distributed.Gives access to distributed cluster state update methods and allows code to inquire whether distributed state update is enabled.Naming of enum instances are the mutator object name (e.g.Class handling the distributed updates of collection's Zookeeper filesstate.jsonbased on multiple updates applied to a single collection (as is sometimes done by *Cmd classes implementing the Collection API commands).A lock that can be used across cluster nodes.A distributed map.A lock as acquired for running a single API command (Collection or Config Set or anything else in the future).Leader Election process.This is a utility class that offers fine grained locking for various Collection Operations This class is designed for single threaded operation.Cluster leader.AnOverseerTaskProcessorthat handles: 1) collection-related Overseer messages 2) configset-related Overseer messagesAOverseerMessageHandlerthat handles ConfigSets API related overseer messages.Interface for processing messages received by anOverseerTaskProcessorResponsible for prioritization of Overseer nodes, for example with the ADDROLE collection command.A generic processor run in the Overseer, used for handling items added to a distributed work queue.An interface to determine whichOverseerMessageHandlerhandles a given message.AZkDistributedQueueaugmented with helper methods specific to the overseer task queues.Start recovery of a core if its term is less than leader's termThis class may change in future and customisations are not supported between versions in terms of API or back compat behaviour.Refresh the ClusterState for a given collection.Hold values of terms, this class is immutable.A size limited distributed map maintained in zk.Used to hold statistics about some SolrCloud operations.SolrCloud Zookeeper ConfigSetService impl.Handle ZooKeeper interactions.Thrown during preregister process if the replica is not present in clusterstateA distributed lock implementation using Zookeeper "directory" nodes created within a collection znode hierarchy, for use with the distributed Collection API implementation.A distributed lock implementation using Zookeeper "directory" nodes created within a collection znode hierarchy, for use with the distributed Collection API implementation.A ZK-based distributed queue.Class used for interact with a ZK term node.ResourceLoader that works with ZooKeeper.