|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use DataSink | |
---|---|
biz.hammurapi.dataflow |
Uses of DataSink in biz.hammurapi.dataflow |
---|
Subinterfaces of DataSink in biz.hammurapi.dataflow | |
---|---|
interface |
DataPipe
Single-input/single-output data processor. |
Classes in biz.hammurapi.dataflow that implement DataSink | |
---|---|
protected class |
DataPump.DataSinkProxy
Blocks sources when stopped. |
class |
DataTypeMatcher
Converts source data items to match types declared. |
class |
JavaMethodDataPipe
Data pipe wrapper for Java method. |
class |
Multiplexor
Dispatches data from source to sinks in the order of addition. |
Fields in biz.hammurapi.dataflow declared as DataSink | |
---|---|
protected DataSink |
AbstractMixer.sink
|
Methods in biz.hammurapi.dataflow that return DataSink | |
---|---|
DataSink |
AbstractMixer.getInput(java.lang.String name)
|
Methods in biz.hammurapi.dataflow with parameters of type DataSink | |
---|---|
void |
DataPump.addConnection(DataSource source,
DataSink sink)
Adds connection to be processed. |
void |
Multiplexor.addSink(DataSink sink)
|
protected abstract void |
AbstractMixer.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. |
void |
AbstractMixer.JoinHelper.join(AbstractMixer.InputEntry[] inputs,
java.lang.String activatorName,
DataSink sink)
|
protected void |
ChainingMixer.join(AbstractMixer.InputEntry[] inputs,
java.lang.String activatorName,
DataSink sink)
|
protected void |
MountingMixer.join(AbstractMixer.InputEntry[] inputs,
java.lang.String activatorName,
DataSink sink)
|
void |
JavaMethodDataPipe.setExceptionHandler(java.lang.Class exceptionType,
DataSink sink)
Sets exception handler. |
void |
AbstractMixer.setSink(DataSink sink)
|
void |
DataSource.setSink(DataSink sink)
Adds data sink to the source. |
void |
DataTypeMatcher.setSink(DataSink sink)
|
void |
JavaMethodDataPipe.setSink(DataSink sink)
|
Constructors in biz.hammurapi.dataflow with parameters of type DataSink | |
---|---|
DataPump.DataSinkProxy(DataSink sink)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |