Package bbflow

package bbflow
BBFlow package with all building blocks
  • Classes
    Class
    Description
    bb_settings
    Global settings for the bbflow package
    block<T,U>
    the basic entity where all nodes are constructed onto it if a new custom building block is created, all functions MUST be extended
    customWatch
    custom time watch class to measure & print performance
    defaultCollector<T>
    default Collector of bbflow.ff_farm.
    defaultEmitter<T>
    default Emitter of bbflow.ff_farm.
    defaultJob<T,U>
    default Job extecuted by the bbflow.ff_node.
    defaultWorker<T,U>
    default worker extending default job it should be extended doing nothing
    ff_all2all<T,U,V,W>
    All2All Building Block able to merge multiple farms
    ff_comb<T,V>
    Combine two nodes (of type ff_node or ff_comb) in one.
    ff_farm<T,U>
    Fundamental block modeling the Farm paradigm Composed by one emitter (single input by default), n_workers workers and one collector Worker must be implemented; the function runJob or runJobMulti contains the computation part.
    ff_node<T,U>
    Fundamental building block rapresenting a node Implemented and used by other building blocks Support multiple input and output channels Single lock for all input channels and a single lock for all output channels
    ff_pipeline<T,V>
    Pipeline building block allows auto-connection between all types of ff_blocks
    ff_queue<T>
    Default class of the queues.
    ff_queue_TCP<T>
    Queue extending ff_queue exploting a network channel.
    node<T,U>
    Thread running the job for ff_node building block
    pipeline_generic<T,U,V>
    Pipeline building block allows auto-connection between all types of ff_blocks
    preloader
    Class providing a static method used to invite JVM to preload main classes used in BBFlow.
    squeue<T>
    Reimplementation of ConcurrentLinkedQueue in Bounded manner Taken inspiration from Hadoop class BoundedConcurrentLinkedQueue