co.cask.cdap.test.internal

Class DefaultWorkerManager

java.lang.Object

co.cask.cdap.test.AbstractProgramManager<WorkerManager>

co.cask.cdap.test.internal.DefaultWorkerManager

All Implemented Interfaces:

ProgramManager<WorkerManager>, WorkerManager

public class DefaultWorkerManager
extends AbstractProgramManager<WorkerManager>
implements WorkerManager

A default implementation of WorkerManager

Field Summary

Fields inherited from class co.cask.cdap.test.AbstractProgramManager

programId

Constructor Summary

Constructors

Constructor and Description
DefaultWorkerManager(co.cask.cdap.proto.Id.Program programId, AppFabricClient appFabricClient, DefaultApplicationManager applicationManager)

Method Summary

Methods

Modifier and Type	Method and Description
int	getInstances()
void	setInstances(int instances)

Methods inherited from class co.cask.cdap.test.AbstractProgramManager

getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus, waitForStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.test.ProgramManager

getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus

Constructor Detail

DefaultWorkerManager

public DefaultWorkerManager(co.cask.cdap.proto.Id.Program programId,
                    AppFabricClient appFabricClient,
                    DefaultApplicationManager applicationManager)

Method Detail

setInstances

public void setInstances(int instances)

Specified by:

setInstances in interface WorkerManager

getInstances

public int getInstances()

Specified by:

getInstances in interface WorkerManager