public class DefaultWorkerManager extends AbstractProgramManager<WorkerManager> implements WorkerManager
WorkerManagerprogramId| Constructor and Description |
|---|
DefaultWorkerManager(co.cask.cdap.proto.Id.Program programId,
AppFabricClient appFabricClient,
DefaultApplicationManager applicationManager) |
| Modifier and Type | Method and Description |
|---|---|
int |
getInstances() |
void |
setInstances(int instances) |
getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus, waitForStatusclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatuspublic DefaultWorkerManager(co.cask.cdap.proto.Id.Program programId,
AppFabricClient appFabricClient,
DefaultApplicationManager applicationManager)
public void setInstances(int instances)
setInstances in interface WorkerManagerpublic int getInstances()
getInstances in interface WorkerManagerCopyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.