org.apache.solr.cloud

Class OverseerCollectionMessageHandler

java.lang.Object

org.apache.solr.cloud.OverseerCollectionMessageHandler

All Implemented Interfaces:

OverseerMessageHandler

public class OverseerCollectionMessageHandler
extends Object
implements OverseerMessageHandler

A OverseerMessageHandler that handles Collections API related overseer messages.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.solr.cloud.OverseerMessageHandler

OverseerMessageHandler.ExclusiveMarking

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASYNC
static String	COLL_CONF
static String	COLL_PROP_PREFIX
static Map<String,Object>	COLL_PROPS
static String	CREATE_NODE_SET
static String	CREATEALIAS
static String	CREATECOLLECTION
static String	CREATESHARD
static String	DELETEALIAS
static String	DELETECOLLECTION
static String	DELETEREPLICA
static String	DELETESHARD
static String	MAX_SHARDS_PER_NODE
static String	MIGRATE
static String	NUM_SLICES
static String	RELOADCOLLECTION
static String	REPLICATION_FACTOR
static String	REQUESTID
static String	ROUTER
static String	SHARDS_PROP
static String	SPLITSHARD

Constructor Summary

Constructors

Constructor and Description
OverseerCollectionMessageHandler(ZkStateReader zkStateReader, String myId, ShardHandlerFactory shardHandlerFactory, String adminPath, Overseer.Stats stats, OverseerNodePrioritizer overseerPrioritizer)

Method Summary

Methods

Modifier and Type	Method and Description
OverseerMessageHandler.ExclusiveMarking	checkExclusiveMarking(String collectionName, ZkNodeProps message)
String	getName()
String	getTaskKey(ZkNodeProps message)
String	getTimerName(String operation)
void	markExclusiveTask(String collectionName, ZkNodeProps message)
SolrResponse	processMessage(ZkNodeProps message, String operation)
void	unmarkExclusiveTask(String collectionName, String operation, ZkNodeProps message)

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

REPLICATION_FACTOR

public static final String REPLICATION_FACTOR

See Also:

Constant Field Values

MAX_SHARDS_PER_NODE

public static final String MAX_SHARDS_PER_NODE

See Also:

Constant Field Values

CREATE_NODE_SET

public static final String CREATE_NODE_SET

See Also:

Constant Field Values

DELETECOLLECTION

public static final String DELETECOLLECTION

See Also:

Constant Field Values

CREATECOLLECTION

public static final String CREATECOLLECTION

See Also:

Constant Field Values

RELOADCOLLECTION

public static final String RELOADCOLLECTION

See Also:

Constant Field Values

CREATEALIAS

public static final String CREATEALIAS

See Also:

Constant Field Values

DELETEALIAS

public static final String DELETEALIAS

See Also:

Constant Field Values

SPLITSHARD

public static final String SPLITSHARD

See Also:

Constant Field Values

DELETESHARD

public static final String DELETESHARD

See Also:

Constant Field Values

ROUTER

public static final String ROUTER

See Also:

Constant Field Values

SHARDS_PROP

public static final String SHARDS_PROP

See Also:

Constant Field Values

ASYNC

public static final String ASYNC

See Also:

Constant Field Values

CREATESHARD

public static final String CREATESHARD

See Also:

Constant Field Values

DELETEREPLICA

public static final String DELETEREPLICA

See Also:

Constant Field Values

MIGRATE

public static final String MIGRATE

See Also:

Constant Field Values

REQUESTID

public static final String REQUESTID

See Also:

Constant Field Values

COLL_CONF

public static final String COLL_CONF

See Also:

Constant Field Values

COLL_PROP_PREFIX

public static final String COLL_PROP_PREFIX

See Also:

Constant Field Values

COLL_PROPS

public static final Map<String,Object> COLL_PROPS

Constructor Detail

OverseerCollectionMessageHandler

public OverseerCollectionMessageHandler(ZkStateReader zkStateReader,
                                String myId,
                                ShardHandlerFactory shardHandlerFactory,
                                String adminPath,
                                Overseer.Stats stats,
                                OverseerNodePrioritizer overseerPrioritizer)

Method Detail

processMessage

public SolrResponse processMessage(ZkNodeProps message,
                          String operation)

Specified by:

processMessage in interface OverseerMessageHandler

Parameters:

message - the message to process

operation - the operation to process

Returns:

response

getName

public String getName()

Specified by:

getName in interface OverseerMessageHandler

Returns:

the name of the OverseerMessageHandler

getTimerName

public String getTimerName(String operation)

Specified by:

getTimerName in interface OverseerMessageHandler

Parameters:

operation - the operation to be timed

Returns:

the name of the timer to use for the operation

getTaskKey

public String getTaskKey(ZkNodeProps message)

Specified by:

getTaskKey in interface OverseerMessageHandler

Parameters:

message - the message being processed

Returns:

the taskKey for the message for handling task exclusivity

markExclusiveTask

public void markExclusiveTask(String collectionName,
                     ZkNodeProps message)

Specified by:

markExclusiveTask in interface OverseerMessageHandler

Parameters:

collectionName - the key associated with the task, cached from getTaskKey

message - the message being processed

unmarkExclusiveTask

public void unmarkExclusiveTask(String collectionName,
                       String operation,
                       ZkNodeProps message)

Specified by:

unmarkExclusiveTask in interface OverseerMessageHandler

Parameters:

collectionName - the key associated with the task

operation - the operation being processed

message - the message being processed

checkExclusiveMarking

public OverseerMessageHandler.ExclusiveMarking checkExclusiveMarking(String collectionName,
                                                            ZkNodeProps message)

Specified by:

checkExclusiveMarking in interface OverseerMessageHandler

Parameters:

collectionName - the key associated with the task

message - the message being processed

Returns:

the exclusive marking