Package tests.MSOM

Class Collector

java.lang.Object

bbflow.defaultJob<T,T>

bbflow.defaultCollector<SOMData>

tests.MSOM.Collector

All Implemented Interfaces:

Runnable

public class Collector
extends defaultCollector<SOMData>

this is our Collector, waiting result from ALL workers in case of SEARCH and waiting ONLY from node involved in case of LEARN. Result sent to Emitter through feedback channel

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean[]	ignore_channels
(package private) int	listeningState
(package private) int	parts
(package private) int	receivedcount
(package private) bestPosition	result
(package private) int	split
(package private) int	waitingnode
final int	WAITSINGLE

Fields inherited from class bbflow.defaultCollector

FIRSTCOME, GATHER, position, ROUNDROBIN

Fields inherited from class bbflow.defaultJob

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

Constructor Summary

Constructors

Constructor	Description
Collector(int parts)

Method Summary

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

Methods inherited from class bbflow.defaultCollector

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

receivedcount

int receivedcount

result

bestPosition result

parts

int parts

split

int split

listeningState

int listeningState

WAITSINGLE

public final int WAITSINGLE

See Also:

• Constant Field Values

waitingnode

int waitingnode

ignore_channels

boolean[] ignore_channels

Constructor Details

Collector

public Collector(int parts)

Method Details

initChannels

public void initChannels()

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 defaultCollector<SOMData>

Throws:

InterruptedException

EOS

public void EOS()

Description copied from class: defaultJob

EOS() function to override

Overrides:

EOS in class defaultJob<SOMData,SOMData>