Uses of Class
io.druid.indexing.overlord.config.RemoteTaskRunnerConfig

Packages that use RemoteTaskRunnerConfig

Package	Description
io.druid.indexing.overlord
io.druid.indexing.overlord.setup
io.druid.indexing.worker

Uses of RemoteTaskRunnerConfig in io.druid.indexing.overlord

Constructors in io.druid.indexing.overlord with parameters of type RemoteTaskRunnerConfig

Constructor and Description
RemoteTaskRunner(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, RemoteTaskRunnerConfig config, IndexerZkConfig indexerZkConfig, org.apache.curator.framework.CuratorFramework cf, PathChildrenCacheFactory pathChildrenCacheFactory, com.metamx.http.client.HttpClient httpClient, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ScheduledExecutorService cleanupExec)
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, com.metamx.common.concurrent.ScheduledExecutorFactory factory)

Uses of RemoteTaskRunnerConfig in io.druid.indexing.overlord.setup

Methods in io.druid.indexing.overlord.setup with parameters of type RemoteTaskRunnerConfig

Modifier and Type	Method and Description
String	JavaScriptWorkerSelectStrategy.SelectorFunction.apply(RemoteTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableZkWorker>	WorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers, Task task) Customizable logic for selecting a worker to run a task.
com.google.common.base.Optional<ImmutableZkWorker>	JavaScriptWorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableZkWorker>	FillCapacityWorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableZkWorker>	FillCapacityWithAffinityWorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableZkWorker>	EqualDistributionWorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers, Task task)

Uses of RemoteTaskRunnerConfig in io.druid.indexing.worker

Constructors in io.druid.indexing.worker with parameters of type RemoteTaskRunnerConfig

Constructor and Description
WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, IndexerZkConfig indexerZkConfig, RemoteTaskRunnerConfig config, org.apache.curator.framework.CuratorFramework curatorFramework, Worker worker)