|
|||||||||
前のクラス 次のクラス | フレームあり フレームなし | ||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
public interface ProducerConsumerCompatible
Producer-Consumerパターンに基づいたデータ処理モジュールのインターフェースです. このインターフェースでは, 1つ以上のキューから要素を1つずつ取り出して, 何らかの処理を行った後, 処理結果を別のキューに書き込みます. 各モジュールには, 基本的には入力チャンネルと出力チャンネルが各々1つ以上あり, 各チャンネルにキューが接続される形になります.
メソッドの概要 | |
---|---|
void |
execute(SPElement[] src,
TimeSeriesCompatible<SPElement>[] dest)
ここに処理内容を記述します. |
java.lang.Class<SPElement>[] |
getInputClasses()
各入力チャンネルが受け付けるオブジェクトのクラスを配列で返します. |
java.lang.Class<SPElement>[] |
getOutputClasses()
各出力チャンネルが出力するオブジェクトのクラスを配列で返します. |
void |
setParams(java.util.Map<java.lang.String,java.lang.String> params)
|
void |
stop(QueueReader<SPElement>[] src,
TimeSeriesCompatible<SPElement>[] dest)
モジュールの処理が終了したときにSPExecutorから呼び出されます |
メソッドの詳細 |
---|
void setParams(java.util.Map<java.lang.String,java.lang.String> params)
void execute(SPElement[] src, TimeSeriesCompatible<SPElement>[] dest) throws java.lang.InterruptedException
src
- 全入力チャンネルに対するQueueReaderオブジェクトdest
- 全出力チャンネル
java.lang.InterruptedException
void stop(QueueReader<SPElement>[] src, TimeSeriesCompatible<SPElement>[] dest)
java.lang.Class<SPElement>[] getInputClasses()
java.lang.Class<SPElement>[] getOutputClasses()
|
|||||||||
前のクラス 次のクラス | フレームあり フレームなし | ||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |