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	COLL_CONF
static String	COLL_PROP_PREFIX
static Map<String,Object>	COLL_PROPS
static String	CREATE_NODE_SET
static String	CREATE_NODE_SET_EMPTY
static String	CREATE_NODE_SET_SHUFFLE
static String	NUM_SLICES
static String	ONLY_ACTIVE_NODES
static String	ONLY_IF_DOWN
static String	REQUESTID
static String	ROUTER
static String	SHARD_UNIQUE
static String	SHARDS_PROP

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
OverseerMessageHandler.ExclusiveMarking	checkExclusiveMarking(String collectionName, ZkNodeProps message)
protected void	crossCheckReplicaStateWithLiveNodes(List<String> liveNodes, NamedList<Object> collectionProps) Walks the tree of collection status to verify that any replicas not reporting a "down" status is on a live node, if any replicas reporting their status as "active" but the node is not live is marked as "down"; used by CLUSTERSTATUS.
String	getName()
String	getTaskKey(ZkNodeProps message)
String	getTimerName(String operation)
void	markExclusiveTask(String collectionName, ZkNodeProps message)
SolrResponse	processMessage(ZkNodeProps message, String operation)
static void	sendShardRequest(String nodeName, ModifiableSolrParams params, ShardHandler shardHandler, String asyncId, Map<String,String> requestMap, String adminPath, ZkStateReader zkStateReader)
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

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

ROUTER

public static final String ROUTER

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

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

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

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,
                                Overseer overseer,
                                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

crossCheckReplicaStateWithLiveNodes

protected void crossCheckReplicaStateWithLiveNodes(List<String> liveNodes,
                                       NamedList<Object> collectionProps)

Walks the tree of collection status to verify that any replicas not reporting a "down" status is on a live node, if any replicas reporting their status as "active" but the node is not live is marked as "down"; used by CLUSTERSTATUS.

Parameters:

liveNodes - List of currently live node names.

collectionProps - Map of collection status information pulled directly from ZooKeeper.

sendShardRequest

public static void sendShardRequest(String nodeName,
                    ModifiableSolrParams params,
                    ShardHandler shardHandler,
                    String asyncId,
                    Map<String,String> requestMap,
                    String adminPath,
                    ZkStateReader zkStateReader)

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