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 Map<String,Object>	COLLECTION_PROPS_AND_DEFAULTS
static String	CREATE_NODE_SET
static String	CREATE_NODE_SET_EMPTY
static String	CREATE_NODE_SET_SHUFFLE
static boolean	CREATE_NODE_SET_SHUFFLE_DEFAULT
static String	NUM_SLICES
static String	ONLY_ACTIVE_NODES
static String	ONLY_IF_DOWN
static Random	RANDOM
static String	REQUESTID
static String	SHARD_UNIQUE
static 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 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 Detail

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

RANDOM

public static final Random RANDOM

Constructor Detail

CollectionHandlingUtils

public CollectionHandlingUtils()

Method Detail

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)