| Interface | Description |
|---|---|
| IWorkerEventSender |
| Class | Description |
|---|---|
| JMWorkerHandler |
Handles JobMaster to worker messaging
It handles following message types:
JobMasterAPI.RegisterWorker
JobMasterAPI.WorkerStateChange
JobMasterAPI.ListWorkersRequest
|
| JobFailureWatcher | |
| JobMaster |
JobMaster class
It is started for each Twister2 job
It provides:
worker discovery
barrier method
Ping service
|
| WorkerMonitor |
This class monitors upto date list of workers in a job with their status
It handles worker state changes:
worker join,
worker running,
worker completion,
worker failure
|
| ZKJobUpdater | |
| ZKMasterController |