public class OverseerCollectionConfigSetProcessor extends OverseerTaskProcessor
OverseerTaskProcessor
that handles:
1) collection-related Overseer messages
2) configset-related Overseer messagesOverseerTaskProcessor.OverseerMessageHandlerSelector, OverseerTaskProcessor.Runner, OverseerTaskProcessor.TaskBatch
MAX_BLOCKED_TASKS, MAX_PARALLEL_TASKS, selector, tpe
Modifier | Constructor and Description |
---|---|
protected |
OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader,
String myId,
HttpShardHandlerFactory shardHandlerFactory,
String adminPath,
Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerNodePrioritizer,
OverseerTaskQueue workQueue,
DistributedMap runningMap,
DistributedMap completedMap,
DistributedMap failureMap,
SolrMetricsContext solrMetricsContext) |
|
OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader,
String myId,
HttpShardHandler shardHandler,
String adminPath,
Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerNodePrioritizer,
SolrMetricsContext solrMetricsContext) |
amILeader, close, getLeaderId, getLeaderNode, getSortedElectionNodes, getSortedOverseerNodeNames, isClosed, run
public OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader, String myId, HttpShardHandler shardHandler, String adminPath, Stats stats, Overseer overseer, OverseerNodePrioritizer overseerNodePrioritizer, SolrMetricsContext solrMetricsContext)
protected OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader, String myId, HttpShardHandlerFactory shardHandlerFactory, String adminPath, Stats stats, Overseer overseer, OverseerNodePrioritizer overseerNodePrioritizer, OverseerTaskQueue workQueue, DistributedMap runningMap, DistributedMap completedMap, DistributedMap failureMap, SolrMetricsContext solrMetricsContext)
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.