Package tests

Class myjob

java.lang.Object

bbflow.defaultJob<Long,Long>

tests.myjob

All Implemented Interfaces:

Runnable

public class myjob
extends defaultJob<Long,Long>

a defaultJob used for the thesis

Field Summary

Fields inherited from class bbflow.defaultJob

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

Constructor Summary

Constructors

Constructor	Description
myjob()

Method Summary

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

Methods inherited from class bbflow.defaultJob

addInputChannel, addOutputChannel, EOS, getInputChannel, getOutputChannel, init, preload, 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

Constructor Details

myjob

public myjob()

Method Details

runJob

public void runJob()
            throws InterruptedException

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 defaultJob<Long,Long>

Throws:

InterruptedException