edu.iu.dsc.tws.api.resource

Interface IWorker

All Known Implementing Classes:

BasicAuroraContainer, BasicComputation, BasicK8sWorker, BasicMesosContainer, BasicMesosWorker, BasicNetworkTest, BenchWindowTaskWorker, BTAllToAll, CDFWWorker, CommsWorker, DataflowAddNodeExperiment, DataflowNodeExperiment, DataParallelWorker, HadoopTSet, HarpWorker, HelloHarp, HelloTwister2Pytorch, InputDataStreamer, IntervalWindowTopology, MultiComputeTasksGraphExample, MultiSpoutTopology, MultiStageGraph, PageRankWorker, PytorchSampleJob, SentenceWordCountTopology, SingleSourceShortestPathWorker, SlidingWindowTopology, SortJob, SourceTaskDataLoader, StormBenchmark, SVMCommsReducer, SvmSgdAdvancedRunner, SvmSgdIterativeRunner, SvmSgdOnlineRunner, SvmSgdRunner, TaskWorker, TaskWorkerDataLoader, TestForPagerank, TestForSSSP, TSetExecDemo, TumblingWindowTopology, Twister2Mnist, Twister2StormWorker, Twister2WorkerStarter, WordCountTopology, WordCountWorker

public interface IWorker

This is the main point of entry from resource scheduler layer to higher layers of Twister2. Resource scheduler starts an instance of this class for each worker.

Method Summary

Modifier and Type	Method and Description
void	execute(Config config, JobAPI.Job job, IWorkerController workerController, IPersistentVolume persistentVolume, IVolatileVolume volatileVolume) Execute with the resources configured

Method Detail

execute

void execute(Config config,
             JobAPI.Job job,
             IWorkerController workerController,
             IPersistentVolume persistentVolume,
             IVolatileVolume volatileVolume)

Execute with the resources configured

Parameters:

config - configuration

job - the worker id

workerController - the worker controller

persistentVolume - information about persistent file system

volatileVolume - information about volatile file system