org.apache.solr.cloud

Class CloudUtil

java.lang.Object

org.apache.solr.cloud.CloudUtil

public class CloudUtil
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
CloudUtil()

Method Summary

Modifier and Type	Method and Description
static void	checkSharedFSFailoverReplaced(CoreContainer cc, CoreDescriptor desc) See if coreNodeName has been taken over by another baseUrl and unload core + throw exception if it has been.
static CollectionStatePredicate	clusterShape(int expectedShards, int expectedReplicas) Return a CollectionStatePredicate that returns true if a collection has the expected number of active shards and replicas
static CollectionStatePredicate	clusterShape(int expectedShards, int expectedReplicas, boolean withInactive, boolean requireLeaders) Return a CollectionStatePredicate that returns true if a collection has the expected number of shards and replicas.
static Map<String,byte[]>	getTrustedKeys(SolrZkClient zk, String dir) Read the list of public keys from ZK
static boolean	replicaExists(ClusterState clusterState, String collection, String shard, String coreNodeName)
static String	unifiedResourcePath(SolrResourceLoader loader) Returns a displayable unified path to the given resource.
static long	waitForState(SolrCloudManager cloudManager, String collection, long wait, TimeUnit unit, CollectionStatePredicate predicate) Wait for a particular collection state to appear.
static long	waitForState(SolrCloudManager cloudManager, String message, String collection, CollectionStatePredicate predicate) Wait for a particular collection state to appear.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_TIMEOUT

public static final int DEFAULT_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

CloudUtil

public CloudUtil()

Method Detail

checkSharedFSFailoverReplaced

public static void checkSharedFSFailoverReplaced(CoreContainer cc,
                                                 CoreDescriptor desc)

See if coreNodeName has been taken over by another baseUrl and unload core + throw exception if it has been.

replicaExists

public static boolean replicaExists(ClusterState clusterState,
                                    String collection,
                                    String shard,
                                    String coreNodeName)

unifiedResourcePath

public static String unifiedResourcePath(SolrResourceLoader loader)

Returns a displayable unified path to the given resource. For non-solrCloud that will be the same as getConfigDir, but for Cloud it will be getConfigSetZkPath ending in a /

Note: Do not use this to generate a valid file path, but for debug printing etc

Parameters:

loader - Resource loader instance

Returns:

a String of path to resource

getTrustedKeys

public static Map<String,byte[]> getTrustedKeys(SolrZkClient zk,
                                                String dir)

Read the list of public keys from ZK

waitForState

public static long waitForState(SolrCloudManager cloudManager,
                                String message,
                                String collection,
                                CollectionStatePredicate predicate)

Wait for a particular collection state to appear. This is a convenience method using the DEFAULT_TIMEOUT

Parameters:

cloudManager - current instance of SolrCloudManager

message - a message to report on failure

collection - the collection to watch

predicate - a predicate to match against the collection state

waitForState

public static long waitForState(SolrCloudManager cloudManager,
                                String collection,
                                long wait,
                                TimeUnit unit,
                                CollectionStatePredicate predicate)
                         throws InterruptedException,
                                TimeoutException,
                                IOException

Wait for a particular collection state to appear. This is a convenience method using the DEFAULT_TIMEOUT

Parameters:

cloudManager - current instance of SolrCloudManager

collection - the collection to watch

wait - timeout value

unit - timeout unit

predicate - a predicate to match against the collection state

Throws:

InterruptedException

TimeoutException

IOException

clusterShape

public static CollectionStatePredicate clusterShape(int expectedShards,
                                                    int expectedReplicas)

Return a CollectionStatePredicate that returns true if a collection has the expected number of active shards and replicas

Parameters:

expectedShards - expected number of active shards

expectedReplicas - expected number of active replicas

clusterShape

public static CollectionStatePredicate clusterShape(int expectedShards,
                                                    int expectedReplicas,
                                                    boolean withInactive,
                                                    boolean requireLeaders)

Return a CollectionStatePredicate that returns true if a collection has the expected number of shards and replicas.

Note: for shards marked as inactive the current Solr behavior is that replicas remain active. SimCloudManager follows this behavior.

Parameters:

expectedShards - expected number of shards

expectedReplicas - expected number of active replicas per shard

withInactive - if true then count also inactive shards

requireLeaders - if true then require that each shard has a leader