edu.iu.dsc.tws.tset.worker

Interface StreamingTSetIWorker

All Superinterfaces:

IWorker

All Known Implementing Classes:

SDirectExample, SReduceExample, SReduceWindowExample, StreamingTsetExample, SUnionExample

public interface StreamingTSetIWorker
extends IWorker

Method Summary

Modifier and Type	Method and Description
void	buildGraph(StreamingTSetEnvironment env) Build the tset graph according to the streaming logic
default void	execute(Config config, int workerID, IWorkerController workerController, IPersistentVolume persistentVolume, IVolatileVolume volatileVolume) Execute with the resources configured

Method Detail

execute

default void execute(Config config,
                     int workerID,
                     IWorkerController workerController,
                     IPersistentVolume persistentVolume,
                     IVolatileVolume volatileVolume)

Description copied from interface: IWorker

Execute with the resources configured

Specified by:

execute in interface IWorker

Parameters:

config - configuration

workerID - the worker id

workerController - the worker controller

persistentVolume - information about persistent file system

volatileVolume - information about volatile file system

buildGraph

void buildGraph(StreamingTSetEnvironment env)

Build the tset graph according to the streaming logic

Parameters:

env - streaming tset env