OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader,
String myId,
HttpShardHandlerFactory shardHandlerFactory,
String adminPath,
Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerNodePrioritizer,
OverseerTaskQueue workQueue,
DistributedMap runningMap,
DistributedMap completedMap,
DistributedMap failureMap) |
OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader,
String myId,
HttpShardHandler shardHandler,
String adminPath,
Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerNodePrioritizer) |
OverseerTaskProcessor(ZkStateReader zkStateReader,
String myId,
Stats stats,
OverseerTaskProcessor.OverseerMessageHandlerSelector selector,
OverseerNodePrioritizer prioritizer,
OverseerTaskQueue workQueue,
DistributedMap runningMap,
DistributedMap completedMap,
DistributedMap failureMap) |
OverseerTaskQueue(SolrZkClient zookeeper,
String dir,
Stats stats) |
ZkDistributedQueue(SolrZkClient zookeeper,
String dir,
Stats stats) |
ZkDistributedQueue(SolrZkClient zookeeper,
String dir,
Stats stats,
int maxQueueSize) |
ZkDistributedQueue(SolrZkClient zookeeper,
String dir,
Stats stats,
int maxQueueSize,
ConnectionManager.IsClosed higherLevelIsClosed) |