OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader,
String myId,
ShardHandlerFactory shardHandlerFactory,
String adminPath,
Overseer.Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerNodePrioritizer,
OverseerTaskQueue workQueue,
DistributedMap runningMap,
DistributedMap completedMap,
DistributedMap failureMap) |
OverseerCollectionConfigSetProcessor(ZkStateReader zkStateReader,
String myId,
ShardHandler shardHandler,
String adminPath,
Overseer.Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerNodePrioritizer) |
OverseerCollectionMessageHandler(ZkStateReader zkStateReader,
String myId,
ShardHandlerFactory shardHandlerFactory,
String adminPath,
Overseer.Stats stats,
Overseer overseer,
OverseerNodePrioritizer overseerPrioritizer) |
OverseerRoleCmd(OverseerCollectionMessageHandler ocmh,
CollectionParams.CollectionAction operation,
OverseerNodePrioritizer prioritizer) |
OverseerTaskProcessor(ZkStateReader zkStateReader,
String myId,
Overseer.Stats stats,
OverseerTaskProcessor.OverseerMessageHandlerSelector selector,
OverseerNodePrioritizer prioritizer,
OverseerTaskQueue workQueue,
DistributedMap runningMap,
DistributedMap completedMap,
DistributedMap failureMap) |