|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectbiz.hammurapi.dataflow.AbstractMixer
biz.hammurapi.dataflow.ChainingMixer
public class ChainingMixer
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 |
---|
public ChainingMixer(java.lang.String name, AbstractMixer.JoinPredicate predicate)
Method Detail |
---|
protected void join(AbstractMixer.InputEntry[] inputs, java.lang.String activatorName, DataSink sink)
AbstractMixer
join
in class AbstractMixer
inputs
- Inputs for joiningactivatorName
- name of the input which activated this join (newly arrived data)sink
- DataSink to write results of joining to (if any).public java.lang.String getName()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |