public class OverseerCollectionMessageHandler extends Object implements OverseerMessageHandler, SolrCloseable
OverseerMessageHandler
that handles Collections API related
overseer messages.Modifier and Type | Class and Description |
---|---|
protected static interface |
OverseerCollectionMessageHandler.Cmd |
class |
OverseerCollectionMessageHandler.ShardRequestTracker |
OverseerMessageHandler.Lock
Modifier and Type | Field and Description |
---|---|
static String |
COLL_PROP_PREFIX |
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 |
FAILURE_FIELD |
static String |
NUM_SLICES |
static String |
ONLY_ACTIVE_NODES |
static String |
ONLY_IF_DOWN |
protected static Random |
RANDOM |
static String |
REQUESTID |
static String |
ROUTER |
static String |
SHARD_UNIQUE |
static String |
SHARDS_PROP |
static String |
SUCCESS_FIELD |
Constructor and Description |
---|
OverseerCollectionMessageHandler(ZkStateReader zkStateReader,
String myId,
HttpShardHandlerFactory shardHandlerFactory,
String adminPath,
Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerPrioritizer) |
Modifier and Type | Method and Description |
---|---|
OverseerCollectionMessageHandler.ShardRequestTracker |
asyncRequestTracker(String asyncId) |
void |
close() |
static void |
createConfNode(DistribStateManager stateManager,
String configName,
String coll,
boolean isLegacyCloud)
This doesn't validate the config (path) itself and is just responsible for creating the confNode.
|
String |
getName() |
String |
getTaskKey(ZkNodeProps message) |
String |
getTimerName(String operation) |
boolean |
isClosed() |
OverseerMessageHandler.Lock |
lockTask(ZkNodeProps message,
OverseerTaskProcessor.TaskBatch taskBatch)
Try to provide an exclusive lock for this particular task
return null if locking is not possible.
|
SolrResponse |
processMessage(ZkNodeProps message,
String operation) |
OverseerCollectionMessageHandler.ShardRequestTracker |
syncRequestTracker() |
public static final String NUM_SLICES
public static final boolean CREATE_NODE_SET_SHUFFLE_DEFAULT
public static final String CREATE_NODE_SET_SHUFFLE
public static final String CREATE_NODE_SET_EMPTY
public static final String CREATE_NODE_SET
public static final String ROUTER
public static final String SHARDS_PROP
public static final String REQUESTID
public static final String COLL_PROP_PREFIX
public static final String ONLY_IF_DOWN
public static final String SHARD_UNIQUE
public static final String ONLY_ACTIVE_NODES
public static final String FAILURE_FIELD
public static final String SUCCESS_FIELD
protected static final Random RANDOM
public OverseerCollectionMessageHandler(ZkStateReader zkStateReader, String myId, HttpShardHandlerFactory shardHandlerFactory, String adminPath, Stats stats, Overseer overseer, OverseerNodePrioritizer overseerPrioritizer)
public SolrResponse processMessage(ZkNodeProps message, String operation)
processMessage
in interface OverseerMessageHandler
message
- the message to processoperation
- the operation to processpublic static void createConfNode(DistribStateManager stateManager, String configName, String coll, boolean isLegacyCloud) throws IOException, AlreadyExistsException, BadVersionException, org.apache.zookeeper.KeeperException, InterruptedException
IOException
AlreadyExistsException
BadVersionException
org.apache.zookeeper.KeeperException
InterruptedException
public String getName()
getName
in interface OverseerMessageHandler
public String getTimerName(String operation)
getTimerName
in interface OverseerMessageHandler
operation
- the operation to be timedpublic String getTaskKey(ZkNodeProps message)
getTaskKey
in interface OverseerMessageHandler
message
- the message being processedpublic OverseerMessageHandler.Lock lockTask(ZkNodeProps message, OverseerTaskProcessor.TaskBatch taskBatch)
OverseerMessageHandler
lockTask
in interface OverseerMessageHandler
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public boolean isClosed()
isClosed
in interface SolrCloseable
public OverseerCollectionMessageHandler.ShardRequestTracker syncRequestTracker()
public OverseerCollectionMessageHandler.ShardRequestTracker asyncRequestTracker(String asyncId)
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.