biz.hammurapi.dataflow
Class ChainingMixer

java.lang.Object
  extended by biz.hammurapi.dataflow.AbstractMixer
      extended by biz.hammurapi.dataflow.ChainingMixer
All Implemented Interfaces:
DataSource

public class ChainingMixer
extends AbstractMixer


Nested Class Summary
 
Nested classes/interfaces inherited from class biz.hammurapi.dataflow.AbstractMixer
AbstractMixer.InputEntry, AbstractMixer.JoinHelper, AbstractMixer.JoinPredicate
 
Field Summary
 
Fields inherited from class biz.hammurapi.dataflow.AbstractMixer
sink
 
Constructor Summary
ChainingMixer(java.lang.String name, AbstractMixer.JoinPredicate predicate)
           
 
Method Summary
 java.lang.String getName()
           
protected  void join(AbstractMixer.InputEntry[] inputs, java.lang.String activatorName, DataSink sink)
          Abstract mixer presents all permutations of newly arrived data from given input with previously arrived data from other inputs plus null values to include cases with inputs without data.
 
Methods inherited from class biz.hammurapi.dataflow.AbstractMixer
addData, chainInputs, controlsMultiplexing, createData, createDataCollection, getDataInfo, getInput, mountInputs, setSink
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ChainingMixer

public ChainingMixer(java.lang.String name,
                     AbstractMixer.JoinPredicate predicate)
Method Detail

join

protected void join(AbstractMixer.InputEntry[] inputs,
                    java.lang.String activatorName,
                    DataSink sink)
Description copied from class: AbstractMixer
Abstract mixer presents all permutations of newly arrived data from given input with previously arrived data from other inputs plus null values to include cases with inputs without data.

Specified by:
join in class AbstractMixer
Parameters:
inputs - Inputs for joining
activatorName - name of the input which activated this join (newly arrived data)
sink - DataSink to write results of joining to (if any).

getName

public java.lang.String getName()


Copyright © 2005 Hammurapi Group. All Rights Reserved.