public class SimpleResourceManagementStrategy extends Object implements ResourceManagementStrategy<RemoteTaskRunner>
Constructor and Description |
---|
SimpleResourceManagementStrategy(SimpleResourceManagementConfig config,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
com.metamx.common.concurrent.ScheduledExecutorFactory factory) |
SimpleResourceManagementStrategy(SimpleResourceManagementConfig config,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
ScheduledExecutorService exec) |
Modifier and Type | Method and Description |
---|---|
ScalingStats |
getStats()
Get any interesting stats related to scaling
|
Collection<ZkWorker> |
getWorkers(RemoteTaskRunner runner) |
void |
startManagement(RemoteTaskRunner runner)
Equivalent to start() but requires a specific runner instance which holds state of interest.
|
void |
stopManagement()
Equivalent to stop()
Should be called from TaskRunner's lifecycle
|
@Inject public SimpleResourceManagementStrategy(SimpleResourceManagementConfig config, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ResourceManagementSchedulerConfig resourceManagementSchedulerConfig, com.metamx.common.concurrent.ScheduledExecutorFactory factory)
public SimpleResourceManagementStrategy(SimpleResourceManagementConfig config, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ResourceManagementSchedulerConfig resourceManagementSchedulerConfig, ScheduledExecutorService exec)
public void startManagement(RemoteTaskRunner runner)
ResourceManagementStrategy
startManagement
in interface ResourceManagementStrategy<RemoteTaskRunner>
runner
- The TaskRunner state holder this strategy should use during executionpublic void stopManagement()
ResourceManagementStrategy
stopManagement
in interface ResourceManagementStrategy<RemoteTaskRunner>
public ScalingStats getStats()
ResourceManagementStrategy
getStats
in interface ResourceManagementStrategy<RemoteTaskRunner>
public Collection<ZkWorker> getWorkers(RemoteTaskRunner runner)
Copyright © 2011–2016. All rights reserved.