io.druid.indexing.overlord

Class RemoteTaskRunnerFactory

java.lang.Object

io.druid.indexing.overlord.RemoteTaskRunnerFactory

All Implemented Interfaces:

TaskRunnerFactory<RemoteTaskRunner>

public class RemoteTaskRunnerFactory
extends Object
implements TaskRunnerFactory<RemoteTaskRunner>

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE_NAME

Constructor Summary

Constructors

Constructor and Description

RemoteTaskRunnerFactory(org.apache.curator.framework.CuratorFramework curator, RemoteTaskRunnerConfig remoteTaskRunnerConfig, IndexerZkConfig zkPaths, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.metamx.http.client.HttpClient httpClient, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ScheduledExecutorFactory factory, ResourceManagementSchedulerConfig resourceManagementSchedulerConfig, ResourceManagementStrategy resourceManagementStrategy)

Method Summary

Modifier and Type	Method and Description
RemoteTaskRunner	build()

Methods inherited from class java.lang.Object

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

Field Detail

TYPE_NAME

public static final String TYPE_NAME

See Also:

Constant Field Values

Constructor Detail

RemoteTaskRunnerFactory

@Inject
public RemoteTaskRunnerFactory(org.apache.curator.framework.CuratorFramework curator,
                                       RemoteTaskRunnerConfig remoteTaskRunnerConfig,
                                       IndexerZkConfig zkPaths,
                                       com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                       com.metamx.http.client.HttpClient httpClient,
                                       com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
                                       ScheduledExecutorFactory factory,
                                       ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
                                       ResourceManagementStrategy resourceManagementStrategy)

Method Detail

build

public RemoteTaskRunner build()

Specified by:

build in interface TaskRunnerFactory<RemoteTaskRunner>