OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader,
String myId,
ShardHandlerFactory shardHandlerFactory,
String adminPath,
Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerNodePrioritizer,
OverseerTaskQueue workQueue,
DistributedMap runningMap,
DistributedMap completedMap,
DistributedMap failureMap) |
OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader,
String myId,
ShardHandler shardHandler,
String adminPath,
Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerNodePrioritizer) |
OverseerCollectionMessageHandler(ZkStateReader zkStateReader,
String myId,
ShardHandlerFactory shardHandlerFactory,
String adminPath,
Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerPrioritizer) |
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) |