私は esper エンジンについては初めてで、複数のストリームの意味がわかりません。私はこのようなものを作成したい:
CepEnigine cep = new CepEngine();
Controller.getInstance().setRuntime(cep.getRuntime());
for(int i = 0; i < 5; i++)
new EventGenerator().start();
イベント ジェネレータ クラスは次のように定義されます。
public class EventGenerator extends Thread
{
@Override
public void run()
{
while (true)
{
MyEvent e = new Event();
Controller.getInstance().sendToCEP(e);
Thread.sleep(500);
}
}
}
コントローラーは、epruntime を保持してイベントを送信するマルチスレッド シングルトンです。CepEngine クラスには、イベントをリッスンするための EPL ステートメントもあります。これは、複数のイベント ストリームの良い意味ですか?
THX