Package org.apache.solr.cloud.api.collections

Class CollectionHandlingUtils

java.lang.Object

org.apache.solr.cloud.api.collections.CollectionHandlingUtils

public class CollectionHandlingUtils
extends Object

This class contains helper methods used by commands of the Collection API. Previously these methods were in OverseerCollectionMessageHandler and were refactored out to (eventually) allow Collection API commands to be executed outside the context of the Overseer.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CollectionHandlingUtils.ShardRequestTracker

Field Summary

Fields

Modifier and Type	Field	Description
static final Map<String,Object>	COLLECTION_PROPS_AND_DEFAULTS
static final String	CREATE_NODE_SET
static final String	CREATE_NODE_SET_EMPTY
static final String	CREATE_NODE_SET_SHUFFLE
static final boolean	CREATE_NODE_SET_SHUFFLE_DEFAULT
static final String	NUM_SLICES
static final String	ONLY_ACTIVE_NODES
static final String	ONLY_IF_DOWN
static final String	REQUESTID
static final String	SHARD_UNIQUE
static final String	SHARDS_PROP

Constructor Summary

Constructors

Constructor	Description
CollectionHandlingUtils()

Method Summary

Modifier and Type	Method	Description
static void	addExceptionToNamedList(Object operation, Exception e, org.apache.solr.common.util.NamedList<Object> results)	Creates a SimpleOrderedMap with the exception details and adds it to the results
static CollectionHandlingUtils.ShardRequestTracker	asyncRequestTracker(String asyncId, CollectionCommandContext ccc)
static EnumSet<org.apache.solr.common.cloud.Replica.Type>	leaderEligibleReplicaTypes()	Returns replica types that are eligible to be leader.
static Set<String>	numReplicasProperties()	Returns names of properties that are used to specify a number of replicas of a given type.
static CollectionHandlingUtils.ShardRequestTracker	syncRequestTracker(CollectionCommandContext ccc)
static String	waitForCoreNodeName(String collectionName, String msgNodeName, String msgCore, org.apache.solr.common.cloud.ZkStateReader zkStateReader)

Methods inherited from class java.lang.Object

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

Field Details

NUM_SLICES

public static final String NUM_SLICES

See Also:

• Constant Field Values

CREATE_NODE_SET_SHUFFLE_DEFAULT

public static final boolean CREATE_NODE_SET_SHUFFLE_DEFAULT

See Also:

• Constant Field Values

CREATE_NODE_SET_SHUFFLE

public static final String CREATE_NODE_SET_SHUFFLE

See Also:

• Constant Field Values

CREATE_NODE_SET_EMPTY

public static final String CREATE_NODE_SET_EMPTY

See Also:

• Constant Field Values

CREATE_NODE_SET

public static final String CREATE_NODE_SET

See Also:

• Constant Field Values

SHARDS_PROP

public static final String SHARDS_PROP

See Also:

• Constant Field Values

REQUESTID

public static final String REQUESTID

See Also:

• Constant Field Values

ONLY_IF_DOWN

public static final String ONLY_IF_DOWN

See Also:

• Constant Field Values

SHARD_UNIQUE

public static final String SHARD_UNIQUE

See Also:

• Constant Field Values

ONLY_ACTIVE_NODES

public static final String ONLY_ACTIVE_NODES

See Also:

• Constant Field Values

COLLECTION_PROPS_AND_DEFAULTS

public static final Map<String,Object> COLLECTION_PROPS_AND_DEFAULTS

Constructor Details

CollectionHandlingUtils

public CollectionHandlingUtils()

Method Details

numReplicasProperties

public static Set<String> numReplicasProperties()

Returns names of properties that are used to specify a number of replicas of a given type.

leaderEligibleReplicaTypes

public static EnumSet<org.apache.solr.common.cloud.Replica.Type> leaderEligibleReplicaTypes()

Returns replica types that are eligible to be leader.

waitForCoreNodeName

public static String waitForCoreNodeName(String collectionName,
 String msgNodeName,
 String msgCore,
 org.apache.solr.common.cloud.ZkStateReader zkStateReader)

addExceptionToNamedList

public static void addExceptionToNamedList(Object operation,
 Exception e,
 org.apache.solr.common.util.NamedList<Object> results)

Creates a SimpleOrderedMap with the exception details and adds it to the results

syncRequestTracker

public static CollectionHandlingUtils.ShardRequestTracker syncRequestTracker(CollectionCommandContext ccc)

asyncRequestTracker

public static CollectionHandlingUtils.ShardRequestTracker asyncRequestTracker(String asyncId,
 CollectionCommandContext ccc)