Package tests.MSOM

Class Emitter

java.lang.Object

bbflow.defaultJob<T,T>

bbflow.defaultEmitter<SOMData>

tests.MSOM.Emitter

All Implemented Interfaces:

Runnable

public class Emitter
extends defaultEmitter<SOMData>

Emitter receives commands from the external and send to workers what to do. Also received feedbacks from Collector as ACK and if there is a new task to execute. For other informations about MSOM read the thesis.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	command_channel
(package private) boolean	commandRunning
(package private) int	feedback_channel

Fields inherited from class bbflow.defaultEmitter

BROADCAST, ROUNDROBIN, SCATTER

Fields inherited from class bbflow.defaultJob

combined, combined_side, CUSTOM_FUNCTION, id, in, INLINE, INLINE_MULTI, out, runType

Constructor Summary

Constructors

Constructor	Description
Emitter()

Method Summary

Modifier and Type	Method	Description
void	EOS()	EOS() function to override
void	runJob()	blank function that should be overwritten by class extending bbflow.defaultJob.

Methods inherited from class bbflow.defaultEmitter

preload

Methods inherited from class bbflow.defaultJob

addInputChannel, addOutputChannel, getInputChannel, getOutputChannel, init, removeInputChannel, removeOutputChannel, run, runJob, runJobMulti, sendEOS, sendEOS, sendOut, sendOut, sendOutTo, sendOutTo, sendOutToAll, setId, uniqueJob, uniqueJob

Methods inherited from class java.lang.Object

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

Field Details

command_channel

int command_channel

feedback_channel

int feedback_channel

commandRunning

boolean commandRunning

Constructor Details

Emitter

public Emitter()

Method Details

runJob

public void runJob()

Description copied from class: defaultJob

blank function that should be overwritten by class extending bbflow.defaultJob. Here main computation task is done once we're sure there's data in at least one of the input channels Lists 'in' and 'out' must be used manually and EOS() must be managed by the user.

Overrides:

runJob in class defaultEmitter<SOMData>

EOS

public void EOS()

Description copied from class: defaultJob

EOS() function to override

Overrides:

EOS in class defaultJob<SOMData,SOMData>