io.druid.server.coordinator

Class LoadQueueTaskMaster

java.lang.Object

io.druid.server.coordinator.LoadQueueTaskMaster

public class LoadQueueTaskMaster
extends Object

Provides LoadQueuePeons

Constructor Summary

Constructors

Constructor and Description
LoadQueueTaskMaster(org.apache.curator.framework.CuratorFramework curator, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, ScheduledExecutorService peonExec, ExecutorService callbackExec, DruidCoordinatorConfig config, HttpClient httpClient, ZkPathsConfig zkPaths)

Method Summary

Modifier and Type	Method and Description
LoadQueuePeon	giveMePeon(ImmutableDruidServer server)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LoadQueueTaskMaster

@Inject
public LoadQueueTaskMaster(org.apache.curator.framework.CuratorFramework curator,
                                   com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                   ScheduledExecutorService peonExec,
                                   ExecutorService callbackExec,
                                   DruidCoordinatorConfig config,
                                   HttpClient httpClient,
                                   ZkPathsConfig zkPaths)

Method Detail

giveMePeon

public LoadQueuePeon giveMePeon(ImmutableDruidServer server)