| Interface | Description |
|---|---|
| IAllJoinedListener |
Workers can be informed when all workers joined the job
|
| IJobMasterFailureListener | |
| InitBarrierListener | |
| IPersistentVolume | |
| IReceiverFromDriver | |
| IScalerListener |
IWorker should listen on this interface to get scaling events from the driver
|
| ISenderToDriver |
A messenger interface to send messages from a worker to the driver in a job
|
| IVolatileVolume |
this is a volatile volume for a worker
it is on the local disk of the node
it will be erased after the worker has completed its work
|
| IWorker |
This is the main point of entry from resource scheduler layer to higher layers of Twister2.
|
| IWorkerController |
an interface to get the list of workers in a job and their addresses
|
| IWorkerFailureListener |
An interface to receive worker failures in Twister2 jobs
|
| IWorkerStatusListener | |
| IWorkerStatusUpdater |
Implementing component lets updating the status of a worker
It also lets retrieving the last status of all workers
|
| Twister2Worker |
| Class | Description |
|---|---|
| ControllerContext | |
| FSPersistentVolume |
todo could move to common
|
| Network |
A util class to initialize the Worker Network
|
| WorkerEnvironment |
Worker environment encapsulating the details about the workers.
|