defaultCollector

java.lang.Object

bbflow.defaultJob<T,T>

bbflow.defaultCollector<T>

Type Parameters:: T - Custom type of channels

All Implemented Interfaces:: Runnable

Direct Known Subclasses:: Collector

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

default Collector of bbflow.ff_farm. Can be extended and runJob() overwritten

Field Summary

Fields

Modifier and Type

Field

Description

static final int

FIRSTCOME

static final int

GATHER

int

position

static final int

ROUNDROBIN

(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

defaultCollector()

defaultCollector(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
- FIRSTCOME
  
  public static final int FIRSTCOME
  See Also:
  
  Constant Field Values
- ROUNDROBIN
  
  public static final int ROUNDROBIN
  See Also:
  
  Constant Field Values
- GATHER
  
  public static final int GATHER
  See Also:
  
  Constant Field Values
- strategy
  
  int strategy
- position
  
  public int position
Constructor Details
- defaultCollector
  
  public defaultCollector()
- defaultCollector
  
  public defaultCollector(int strategy)
  
  default constructor
  
  Parameters:
  
  strategy - Collector communication strategy chosen between FIRSTCOME, GATHER and ALLGATHER
Method Details
- preload
  
  public static void preload()
- 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<T,T>
  
  Throws:
  
  InterruptedException