Package bbflow

Class defaultEmitter<T>

java.lang.Object

bbflow.defaultJob<T,T>

bbflow.defaultEmitter<T>

Type Parameters:

T - Custom type of channels

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

Emitter

public class defaultEmitter<T>
extends defaultJob<T,T>

default Emitter of bbflow.ff_farm. Implemented various Communication models with workers: ROUNDROBIN, SCATTER, BROADCAST

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BROADCAST
(package private) int	position
static final int	ROUNDROBIN	Communications model
static final int	SCATTER
(package private) int	strategy

Fields inherited from class bbflow.defaultJob

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

Constructor Summary

Constructors

Constructor	Description
defaultEmitter()
defaultEmitter(int strategy)	default constructor

Method Summary

Modifier and Type	Method	Description
static void	preload()
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, 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

ROUNDROBIN

public static final int ROUNDROBIN

Communications model

See Also:

• Constant Field Values

SCATTER

public static final int SCATTER

See Also:

• Constant Field Values

BROADCAST

public static final int BROADCAST

See Also:

• Constant Field Values

strategy

int strategy

position

int position

Constructor Details

defaultEmitter

public defaultEmitter()

defaultEmitter

public defaultEmitter(int strategy)

default constructor

Parameters:

strategy - Emitter communication strategy chosen between ROUNDROBIN, SCATTER and BROADCAST

Method Details

preload

public static void preload()

runJob

public void runJob()
            throws InterruptedException,
InstantiationException,
IllegalAccessException,
NoSuchMethodException,
InvocationTargetException

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<T,T>

Throws:

InterruptedException

InstantiationException

IllegalAccessException

NoSuchMethodException

InvocationTargetException