public class HarkDataStreamReceiver extends SPModule
コンストラクタと説明 |
---|
HarkDataStreamReceiver(int port) |
修飾子とタイプ | メソッドと説明 |
---|---|
void |
execute(java.lang.Object[] src,
TimeSeriesCompatible[] dest)
ここに処理内容を記述します.
|
java.lang.Class[] |
getInputClasses()
各入力チャンネルが受け付けるオブジェクトのクラスを配列で返します.
|
java.lang.Class[] |
getOutputClasses()
各出力チャンネルが出力するオブジェクトのクラスを配列で返します.
|
void |
setTickTimer(TickTimer tt) |
void |
stop()
モジュールの処理が終了したときにSPExecutorから呼び出されます
|
stop, terminated
public HarkDataStreamReceiver(int port) throws java.io.IOException
java.io.IOException
public void execute(java.lang.Object[] src, TimeSeriesCompatible[] dest) throws java.lang.InterruptedException
ProducerConsumerCompatible
src
- 全入力チャンネルに対するQueueReaderオブジェクトdest
- 全出力チャンネルjava.lang.InterruptedException
public java.lang.Class[] getInputClasses()
ProducerConsumerCompatible
public java.lang.Class[] getOutputClasses()
ProducerConsumerCompatible
public void setTickTimer(TickTimer tt)
public void stop()
ProducerConsumerCompatible
stop
インタフェース内 ProducerConsumerCompatible
stop
クラス内 SPModule