Package biz.hammurapi.dataflow

Interface Summary

AbstractMixer.InputEntry	Information about input presented to join().
AbstractMixer.JoinHelper	Joins inputs.
AbstractMixer.JoinPredicate	Decides whether given inputs shall be joined.
Data	Data is a set of named and typed items, or "slots".
DataItemInfo
DataPipe	Single-input/single-output data processor.
DataSink	Data sinks consume data.
DataSource	Source of data.
PersistentData	Persistent data.

Class Summary

AbstractMixer	Base class for mixers which join data.
ChainingMixer
DataFilter	Delegates all calls to the master data.
DataPump	Performs multi-threaded data pumping between data sources and sinks.
DataTypeMatcher	Converts source data items to match types declared.
JavaMethodDataPipe	Data pipe wrapper for Java method.
MapData	Data backed by HashMap.
MountingMixer
Multiplexor	Dispatches data from source to sinks in the order of addition.
PersistentDataFilter	Delegates all calls to the master.

Exception Summary

DataFlowException