edu.iu.dsc.tws.harp

Class HarpWorker

java.lang.Object

edu.iu.dsc.tws.harp.HarpWorker

All Implemented Interfaces:

IWorker

Direct Known Subclasses:

HelloHarp

public abstract class HarpWorker
extends java.lang.Object
implements IWorker

This class starts Harp Servers inside twiser2 worker and allow user to use Harp APIs inside logic execution

Constructor Summary

Constructors

Constructor and Description
HarpWorker()

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
abstract void	executeHarp(Config config, int workerID, int numberOfWorkers, IWorkerController workerController, IPersistentVolume persistentVolume, IVolatileVolume volatileVolume, DataMap harpDataMap, Workers harpWorkers) This method will be called after setting up Harp environment

Methods inherited from class java.lang.Object

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

Constructor Detail

HarpWorker

public HarpWorker()

Method Detail

execute

public void execute(Config config,
                    JobAPI.Job job,
                    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

job - the worker id

workerController - the worker controller

persistentVolume - information about persistent file system

volatileVolume - information about volatile file system

executeHarp

public abstract void executeHarp(Config config,
                                 int workerID,
                                 int numberOfWorkers,
                                 IWorkerController workerController,
                                 IPersistentVolume persistentVolume,
                                 IVolatileVolume volatileVolume,
                                 DataMap harpDataMap,
                                 Workers harpWorkers)

This method will be called after setting up Harp environment